PUB + bind - then - SUB + connect

test.py

import zmq

context = zmq.Context()
address = "inproc://test"

#publisher
pub = context.socket(zmq.PUB)
pub.bind(address)

#subscriber
sub = context.socket(zmq.SUB)
sub.connect(address)
sub.setsockopt(zmq.SUBSCRIBE, "test")
poller = zmq.Poller()
poller.register(sub, zmq.POLLIN)

#send some messages
pub.send("test 123")
pub.send("test 345")
pub.send("foo 23")
pub.send("test hello")

# retrieve
has_next = True
while has_next:
    has_next = False
    sock = dict(poller.poll(100))
    if sub in sock:
        has_next = True
        msg = sub.recv()
        print msg