autobahn-voting-client.py

from twisted.internet import reactor
from twisted.internet.defer import inlineCallbacks

from autobahn.twisted.wamp import ApplicationSession


class Component(ApplicationSession):
    @inlineCallbacks
    def onJoin(self, details):
        print('session attached')

        def on_event(x):
            print('Got event: {}'.format(x))

        yield self.subscribe(on_event, u'io.crossbar.demo.vote.onreset')

    def onDisconnect(self):
        print('disconnected')
        reactor.stop()

if __name__ == '__main__':
    from autobahn.twisted.wamp import ApplicationRunner
    runner = ApplicationRunner(u'wss://demo.crossbar.io/ws', u'crossbardemo')
    runner.run(Component)