9
1
mirror of https://github.com/QuantumPackage/qp2.git synced 2024-12-23 20:13:42 +01:00
qp2/ocaml/tests/test_pub.py

16 lines
275 B
Python
Raw Normal View History

2019-01-25 11:39:31 +01:00
#!/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()