celery.worker.consumer.connection¶

Consumer Broker Connection Bootstep.

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

Service managing the consumer broker connection.

info(c)[source]¶

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

shutdown(c)[source]¶

start(c)[source]¶