diff options
-rwxr-xr-x | zmq-rx.py | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/zmq-rx.py b/zmq-rx.py new file mode 100755 index 0000000..927b5ed --- /dev/null +++ b/zmq-rx.py @@ -0,0 +1,19 @@ +#!/usr/bin/env python + +import sys +import zmq + +context = zmq.Context() + +sock = context.socket(zmq.SUB) + +sock.connect("tcp://localhost:8080") + +sock.setsockopt(zmq.SUBSCRIBE, bytes([])) + +print("Entering loop") +for i in range(10): + data = sock.recv(flags=0, copy=True, track=False) + print("RX {0}B, {1:2x}, {2:2x}, {3:2x}, {4:2x}, ...".format( + len(data), + data[0], data[1], data[2], data[3] )) |