autobahn_twisted_wamp_client_rpc_call.py

1from autobahn.twisted.component import Component, run
2from twisted.internet.defer import inlineCallbacks
3
4# Create a WAMP component
5component = Component(
6    transports=[
7        {
8            "type": "websocket",
9            "url": "ws://localhost:8080/ws",
10            "endpoint": {
11                "type": "tcp",
12                "host": "localhost",
13                "port": 8080,
14            },
15        },
16    ],
17    realm="realm1",
18)
19
20@component.on_join
21@inlineCallbacks
22def joined(session, details):
23    print("Session joined!")
24
25    # Call a remote procedure
26    try:
27        res = yield session.call("com.example.add2", 2, 3)
28        print(f"Result: {res}")
29    except Exception as e:
30        print(f"Call failed: {e}")
31    finally:
32        session.leave()
33
34@component.on_leave
35def left(session, details):
36    print("Session left!")
37
38if __name__ == "__main__":
39    run([component])