Messaging - celery.messaging¶

Sending and Receiving Messages

class celery.messaging.TaskConsumer(connection, queue=None, exchange=None, routing_key=None, **kwargs)¶

The AMQP Task Consumer class.

decoder()¶

loads(string) – Load a pickle from the given string

class celery.messaging.TaskPublisher(connection, exchange=None, routing_key=None, **kwargs)¶

The AMQP Task Publisher class.

delay_task(task_name, task_args, task_kwargs, **kwargs)¶

Delay task for execution by the celery nodes.

delay_task_in_set(taskset_id, task_name, task_args, task_kwargs, **kwargs)¶

Delay a task which part of a task set.

encoder()¶

dumps(obj, protocol=0) – Return a string containing an object in pickle format.

See the Pickler docstring for the meaning of optional argument proto.

requeue_task(task_name, task_id, task_args, task_kwargs, part_of_set=None, **kwargs)¶

Requeue a failed task.