CODEWITHSUNDEEP
pythontwistedautobahnwamp-protocol
John
John

Reputation: 13

Can autobahn.twisted.wamp.Application do pub/sub?

I would like to use some pub/sub features along with rpc from autobahn.twisted.wamp.Application

I'd prefer not to make a ApplicationSession class if I can get by without doing so.

Can registered rpc methods cause client subscriptions and publish? If they can, please show me how.

Upvotes: 1

Views: 673

Answers (1)

oberstet
oberstet

Reputation: 22051

Yes, sure:

def onEvent(msg):
   print("got event: {}".format(msg))

@app.register('com.example.triggersubscribe')
def triggerSubscribe():
   yield app.session.subscribe(onEvent, 'com.example.topic1')

When triggerSubscribe is called (e.g. remotely from another WAMP component), the callee (the WAMP component exposing com.example.triggersubscribe) will dynamically subscribe to com.example.topic1.

You can publish from within a registered procedure also of course: app.session.publish().

I have added the complete example (including JS client) here.

Upvotes: 4

Related Questions