9
1
mirror of https://github.com/QuantumPackage/qp2.git synced 2024-12-27 05:43:31 +01:00
qp2/ocaml/tests/test_pub.py
2019-01-25 11:39:31 +01:00

16 lines
275 B
Python
Executable File

#!/usr/bin/python
import zmq
import sys, os
def main():
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://127.0.0.1:41280")
socket.setsockopt(zmq.SUBSCRIBE, "")
while True:
print socket.recv()
if __name__ == '__main__':
main()