Warning, file /plasma/lancelot/contrib/zmq-utils/zmq-subscriber-test.py was not indexed or was modified since last indexation (in which case cross-reference links may be missing, inaccurate or erroneous).

0001 #!/usr/bin/python3
0002 
0003 import zmq
0004 import time
0005 
0006 context = zmq.Context()
0007 socket = context.socket(zmq.SUB)
0008 socket.connect("ipc:///tmp/ivan-zmq-voy-socket-out")
0009 socket.setsockopt_string(zmq.SUBSCRIBE, '')
0010 
0011 while True:
0012     msg = socket.recv()
0013     # print(str(msg, 'utf-8'))
0014     print(msg)
0015