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.