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)[исходный код]
Вернуться на верх