crossbar.router.broker¶

Classes¶

Basic WAMP broker.

Module Contents¶

class Broker(router, reactor, options=None)[source]¶

Bases: object

Basic WAMP broker.

_filter_publish_receivers(receivers, publish)[source]¶

Internal helper.

Does all filtering on a candidate set of Publish receivers, based on all the white/blacklist options in ‘publish’.

_option_uri_strict[source]¶

_options[source]¶

_reactor[source]¶

_request_id_gen[source]¶

_role_features[source]¶

_router[source]¶

_session_to_subscriptions[source]¶

_subscription_map[source]¶

_unsubscribe(subscription, session, unsubscribe=None)[source]¶

attach(session)[source]¶: Implements crossbar.router.interfaces.IBroker.attach()

detach(session)[source]¶: Implements crossbar.router.interfaces.IBroker.detach()

log[source]¶

processPublish(session, publish)[source]¶: Implements crossbar.router.interfaces.IBroker.processPublish()

processSubscribe(session, subscribe)[source]¶: Implements crossbar.router.interfaces.IBroker.processSubscribe()

processUnsubscribe(session, unsubscribe)[source]¶: Implements crossbar.router.interfaces.IBroker.processUnsubscribe()

removeSubscriber(subscription, session, reason=None)[source]¶: Actively unsubscribe a subscriber session from a subscription.