diff --git a/src/receiver.py b/src/receiver.py new file mode 100644 index 0000000..193eb09 --- /dev/null +++ b/src/receiver.py @@ -0,0 +1,17 @@ +import zmq.green as zmq +import sys + + +def main(): + context = zmq.Context() + subscriber = context.socket(zmq.SUB) + + subscriber.setsockopt(zmq.SUBSCRIBE, "") + subscriber.connect('tcp://199.115.222.234:9500') + + while True: + print subscriber.recv() + sys.stdout.flush() + +if __name__ == '__main__': + main()