Skip to content

Instantly share code, notes, and snippets.

@saghul
Created Jun 25, 2011
Embed
What would you like to do?
ZeroMQ producer example
# producer
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.setsockopt(zmq.LINGER, 0) # discard unsent messages on close
socket.connect('tcp://127.0.0.1:5000')
while True:
msg = raw_input('> ')
if msg == 'quit':
break
else:
socket.send(msg)
socket.close()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment