Messaging - celery.messaging¶

Sending and Receiving Messages

celery.messaging.establish_connection(**kwargs)¶

Establish a connection to the message broker.

celery.messaging.get_consumer_set(connection, queues=None, **options)¶

Get the kombu.messaging.Consumer for a queue configuration.

Defaults to the queues in CELERY_QUEUES.

celery.messaging.with_connection(fun)¶

Decorator for providing default message broker connection for functions supporting the connection and connect_timeout keyword arguments.