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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
from RobotRaconteur.Client import *
import sys
import time
try:
raw_input # type: ignore
except NameError:
raw_input = input
def main():
if (len(sys.argv) < 2):
print("Usage for subscriberurltest: subscriberurltest.py url")
return
url = sys.argv[1]
print(url)
s = RRN.SubscribeService(url)
def connected(s, client_id, client):
print("Client connected: " + str(client_id.NodeID) +
"," + client_id.ServiceName)
def disconnected(s, client_id, client):
print("Client disconnected: " + str(client_id.NodeID) +
"," + client_id.ServiceName)
def connect_failed(s, client_id, url, err):
print("Client connect failed: " + str(client_id.NodeID) +
" url: " + str(url) + " error: " + str(err))
s.ClientConnected += connected
s.ClientDisconnected += disconnected
s.ClientConnectFailed += connect_failed
def async_get_handler(obj, err):
if err is not None:
print("AsyncGetDefaultClient error: " + str(err))
else:
print("AsyncGetDefaultClient success: " + str(obj))
s.AsyncGetDefaultClient(async_get_handler, 1)
client1 = s.GetDefaultClientWait(6)
print(s.TryGetDefaultClientWait(6))
print(s.GetConnectedClients())
try:
print(s.GetDefaultClient().d1)
except:
print("Client not connected")
print(s.TryGetDefaultClient())
raw_input("Press enter")
if __name__ == "__main__":
main()
|
