crossbar.router.dealer

Classes

Dealer

Basic WAMP dealer.

Module Contents

class Dealer(router, reactor, options=None)

Bases: object

Basic WAMP dealer.

_add_invoke_request(invocation_request_id, registration, session, call, callee, forward_for, authorization, timeout=None)

Internal helper. Adds an InvocationRequest to both the _callee_to_invocations and _invocations maps.

_call(session, call, registration, authorization, is_queued_call=False)

_callee_to_invocations

_caller_to_invocations

_cancel_timers

_invocations

_invocations_by_call

_option_uri_strict

_options

_reactor

_registration_map

_remove_invoke_request(invocation_request)

Internal helper. Removes an InvocationRequest from both the _callee_to_invocations and _invocations maps.

_request_id_gen

_role_features

_router

_session_to_registrations

_unregister(registration, session, unregister=None)

attach(session)

Implements crossbar.router.interfaces.IDealer.attach()

detach(session)

Implements crossbar.router.interfaces.IDealer.detach()

log

processCall(session, call: autobahn.wamp.message.Call)

Implements crossbar.router.interfaces.IDealer.processCall()

processCancel(session, cancel)

Implements crossbar.router.interfaces.IDealer.processCancel()

A ‘caller’ has sent us a message wishing to cancel a still- outstanding call. They can request 1 of 3 modes of cancellation.

processInvocationError(session, error)

Implements crossbar.router.interfaces.IDealer.processInvocationError()

processRegister(session, register)

Implements crossbar.router.interfaces.IDealer.processRegister()

processUnregister(session, unregister)

Implements crossbar.router.interfaces.IDealer.processUnregister()

processYield(session, yield_)

Implements crossbar.router.interfaces.IDealer.processYield()

removeCallee(registration, session, reason=None)

Actively unregister a callee session from a registration.