diff --git a/utils/zmq_client.py b/utils/zmq_client.py new file mode 100644 index 0000000000000000000000000000000000000000..60961f8f1ae05e9a07bd6bcf3c095a0ed9f0ad1e --- /dev/null +++ b/utils/zmq_client.py @@ -0,0 +1,15 @@ +import sys +import zmq + +port = "5556" +# Socket to talk to server +context = zmq.Context() +socket = context.socket(zmq.SUB) +socket.connect ("tcp://localhost:12345") + +socket.setsockopt(zmq.SUBSCRIBE, "".encode("utf-8")) + +while True: + string = socket.recv() + topic, messagedata = string.split() + print(topic, messagedata)