Messaging - celery.messaging¶
Sending and Receiving Messages
- class celery.messaging.NoProcessConsumer(connection, queue=None, exchange=None, routing_key=None, **kwargs)¶
- A consumer that raises an error if used with wait callbacks (i.e. it doesn’t support carrot.messaging.Consumer.wait`()).
- class celery.messaging.TaskConsumer(connection, queue=None, exchange=None, routing_key=None, **kwargs)¶
- The AMQP Task Consumer class.
- class celery.messaging.TaskPublisher(connection, exchange=None, routing_key=None, **kwargs)¶
The AMQP Task Publisher class.
- delay_task(task_name, *task_args, **task_kwargs)¶
- Delay task for execution by the celery nodes.
- delay_task_in_set(task_name, taskset_id, task_args, task_kwargs)¶
- Delay a task which part of a task set.
- requeue_task(task_name, task_id, task_args, task_kwargs, part_of_set=None)¶
- Requeue a failed task.