This document describes an older version of Celery (2.5). For the latest stable version please go here.
AMQ related functionality.
copyright: |
|
---|---|
license: | BSD, see LICENSE for more details. |
Broker connection class used. Default is kombu.connection.BrokerConnection.
The task consumer class used. Default is kombu.compat.Consumer.
The class used to consume from multiple queues using the same channel.
Returns the current task router.
Returns consumer for a single task queue.
Returns publisher used to send tasks.
You should use app.send_task instead.
Return consumer configured to consume from all known task queues.
Returns (queue_name, queue_options) tuple for the queue configured to be default (CELERY_DEFAULT_QUEUE).
Queue name⇒ declaration mapping.
Celery will consult this mapping to find the options for any queue by name.
Parameters: | queues – Initial mapping. |
---|
Add new queue.
Parameters: |
|
---|
Creates new option mapping for queue, with required keys present.
Format routing table into string for log dumps.
Select subset of the currently defined queues.
Does not return anything: queues not in wanted will be discarded in-place.
Parameters: |
|
---|
Alternate constructor that adds default exchange and exchange type information to queues that does not have any.
Send task message.