gistfile1.py

from datetime import datetime
from twisted.internet.defer import inlineCallbacks

from autobahn.wamp.types import PublishOptions
from autobahn.twisted.wamp import ApplicationSession
from autobahn.twisted.wamp import ApplicationRunner
from autobahn.twisted.util import sleep


class MyComponent(ApplicationSession):

    @inlineCallbacks
    def onJoin(self, details):
        print("session ready")
        yield self.subscribe(self.run, u"a.topic.name")

        while True:
            yield self.publish(u"a.topic.name", options=PublishOptions(exclude_me=False))
            yield sleep(5)

    def run(self):
        print("run at {}".format(datetime.now()))

runner = ApplicationRunner(url=u"ws://localhost:8080/ws", realm=u"realm1")
runner.run(MyComponent)