Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
ZMQ multicast 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('epgm://239.192.1.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