backends.rpc

The RPC result backend for AMQP brokers.

RPC-style result backend, using reply-to and one queue per client.

Module Contents

Classes

BacklogLimitExceeded() Too much state history to fast-forward.
ResultConsumer(self,*args,**kwargs)
RPCBackend(self,app,connection=None,exchange=None,exchange_type=None,persistent=None,serializer=None,auto_delete=True,**kwargs) Base class for the RPC result backend.

Functions

_on_after_fork_cleanup_backend(backend)
class BacklogLimitExceeded

Too much state history to fast-forward.

_on_after_fork_cleanup_backend(backend)
class ResultConsumer(*args, **kwargs)
__init__(*args, **kwargs)
start(initial_task_id, no_ack=True, **kwargs)
drain_events(timeout=None)
stop()
on_after_fork()
consume_from(task_id)
cancel_for(task_id)
class RPCBackend(app, connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=True, **kwargs)

Base class for the RPC result backend.

class Consumer

Consumer that requires manual declaration of queues.

class Queue

Queue that never caches declaration.

__init__(app, connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=True, **kwargs)
_after_fork()
_create_exchange(name, type="direct", delivery_mode=2)
_create_binding(task_id)

Create new binding for task with id.

ensure_chords_allowed()
on_task_call(producer, task_id)
destination_for(task_id, request)

Get the destination for result by task id.

Returns:
Tuple[str, str]: tuple of (reply_to, correlation_id).
on_reply_declare(task_id)
on_result_fulfilled(result)
as_uri(include_password=True)
store_result(task_id, result, state, traceback=None, request=None, **kwargs)

Send task return value and state.

_to_result(task_id, state, result, traceback, request)
on_out_of_band_result(task_id, message)
get_task_meta(task_id, backlog_limit=1000)
_set_cache_by_message(task_id, message)
_slurp_from_queue(task_id, accept, limit=1000, no_ack=False)
_get_message_task_id(message)
revive(channel)
reload_task_result(task_id)
reload_group_result(task_id)

Reload group result, even if it has been previously fetched.

save_group(group_id, result)
restore_group(group_id, cache=True)
delete_group(group_id)
__reduce__(args=tuple, kwargs=dict)
binding()
oid()