import zmq

ctx=zmq.Context()

sock=ctx.socket(zmq.ROUTER)
sock.hwm=100000
sock.setsockopt(zmq.LINGER, 200)
sock.bind("tcp://127.0.0.1:5556")

print("waiting for messages...")
while 1:
    msg=sock.recv_multipart()
    sock.send(msg[0], zmq.SNDMORE)
    sock.send_unicode("")