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

celery.worker.consumer.connection

Consumer Broker Connection Bootstep.

class celery.worker.consumer.connection.Connection(c, **kwargs)

Service managing the consumer broker connection.

close_connection(c)

Close and clear c.connection.

Used by shutdown() for final cleanup. The error handler in on_connection_error_after_connected() performs the same close inline to release the broken socket before blueprint.restart().

info(c)

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

shutdown(c)

start(c)