This document describes the current stable version of Celery (4.2). For development docs, go here.

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 = u'celery.worker.consumer.connection.Connection'
shutdown(c)[source]
start(c)[source]