Pub/Sub example with ZeroMQ

publish.py

import time
import zmq

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://127.0.0.1:6000")

while True:
  socket.send("Msg")
	time.sleep(1)

subscribe.py

import zmq

from zmq.eventloop.zmqstream import ZMQStream
from zmq.eventloop import ioloop

ioloop.install()

zmq_context = zmq.Context()

subscribe_socket = zmq_context.socket(zmq.SUB)
subscribe_socket.setsockopt(zmq.SUBSCRIBE, '')
subscribe_socket.connect('tcp://127.0.0.1:6000')

def echo(msg):
  print msg

sub_stream = ZMQStream(subscribe_socket)
sub_stream.on_recv(echo)

app_ioloop = ioloop.IOLoop.instance()
app_ioloop.start()