Zmq Tests

puller.py

from zmq import Context, PULL

ctx = Context()
sock = ctx.socket(PULL)
sock.connect("tcp://localhost:5555")
counter = 1
try:
    with open('test.txt', 'w+') as f:
        while True:
            msg = sock.recv()
            print >> f, msg
except KeyboardInterrupt:
    sock.close()
    ctx.term()

pusher.py

from zmq import Context, PUSH

ctx = Context()
sock = ctx.socket(PUSH)
sock.bind("tcp://*:5555")
counter = 1
try:
    while True:
        sock.send("hello %s" % counter)
        counter += 1
except KeyboardInterrupt:
    sock.close()
    ctx.term()