`celery.worker.consumer.connection`¶

Consumer Broker Connection Bootstep.

class celery.worker.consumer.connection.Connection(c, **kwargs)[源代码]¶

Service managing the consumer broker connection.

info(c)[源代码]¶

name = 'celery.worker.consumer.connection.Connection'¶

shutdown(c)[源代码]¶

start(c)[源代码]¶