Minimal example for pyzmq, usable as test-case.

test_pyzmq.py

import threading
import uuid
import time
import zmq



def sender(send_addr, receiver_port):
	send_socket = ctx.socket(zmq.REQ)
	address = "tcp://{addr}:{port}".format(addr=send_addr, port=receiver_port)
	send_socket.connect(address)
	while True:
		msg = uuid.uuid4()
		print "sending: {}".format(msg)

		send_socket.send_string(str(msg))
		if send_socket.recv() == "die":
			return

		time.sleep(3)

def receiver(receiver_port):
	listener = ctx.socket(zmq.REP)
	address = "tcp://*:{port}".format(port=receiver_port)

	listener.bind(address)
	while True:
		msg = listener.recv_string()
		listener.send("ack")

		print "received: {}".format(msg)



if __name__ == "__main__":
	ctx = zmq.Context()
	port = 32429
	send = threading.Thread(target=sender, args=('localhost', port))
	send.start()
	receive = threading.Thread(target=receiver, args=(port,))
	receive.start()