celery.backends.rpc

    class celery.backends.rpc.RPCBackend(app, connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=True, \*kwargs*)

    • class Consumer(channel, queues=None, no_ack=None, auto_declare=None, callbacks=None, on_decode_error=None, on_message=None, accept=None)[源代码]

    • RPCBackend.destination_for(task_id, request)

    • RPCBackend.oid None[源代码]

    • RPCBackend.on_task_call(producer, task_id)

    • RPCBackend.persistent = False