1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
from autobahn.twisted.component import Component, run
# or: from autobahn.asyncio.component import Component, run
from twisted.internet.defer import inlineCallbacks
demo = Component(
transports=[
{
"url": "wss://demo.crossbar.io/ws",
}
],
realm="crossbardemo",
)
# 1. subscribe to a topic
@demo.subscribe('io.crossbar.demo.hello')
def hello(msg):
print("Got hello: {}".format(msg))
# 2. register a procedure for remote calling
@demo.register('io.crossbar.demo.add2')
def add2(x, y):
return x + y
# 3. after we've authenticated, run some code
@demo.on_join
async def joined(session, details):
# publish an event (won't go to "this" session by default)
session.publish('io.crossbar.demo.hello', 'Hello, world!')
# 4. call a remote procedure
result = await session.call('io.crossbar.demo.add2', 2, 3)
print("io.crossbar.demo.add2(2, 3) = {}".format(result))
await session.leave()
if __name__ == "__main__":
run([demo])
|
