eventify.drivers package

Submodules

eventify.drivers.crossbar module

Crossbar Driver Module

class eventify.drivers.crossbar.Component(config=None)

Bases: eventify.drivers.base.BaseComponent, autobahn.asyncio.wamp.ApplicationSession

Handle subscribing to topics

emit_event(event)

Publish an event back to crossbar :param event: Event object

log = <Logger eventify.drivers.crossbar (WARNING)>

lookup_session(topic_name)

Attempts to find the session id for a given topic

http://crossbar.io/docs/Subscription-Meta-Events-and-Procedures/

onClose(wasClean)

Disconnect when connection to message broker is lost

onDisconnect()

Event fired when transport is lost

onJoin(details)

Implements autobahn.wamp.interfaces.ISession.onJoin()

onLeave(reason=None, message=None)

Parameters

• reason –

• message –

onUserError(fail, message)

Handle user errors

show_sessions()

Returns an object with a lists of the session IDs for all sessions currently attached to the realm

http://crossbar.io/docs/Session-Metaevents-and-Procedures/

total_sessions()

Returns the number of sessions currently attached to the realm.

http://crossbar.io/docs/Session-Metaevents-and-Procedures/

class eventify.drivers.crossbar.Service(driver='crossbar', config_file='config.json', handlers=None)

Bases: eventify.Eventify

Create crossbar service

check_transport_host()

Check if crossbar port is open on transport host

reconnect()

Handle reconnect logic if connection to crossbar is lost

setup_runner()

Setup instance of runner var

start(start_loop=True)

Start a producer/consumer service

Module contents