A simple zeromq PUSH-PULL streamer device

broker.py

#!/usr/bin/env python

import zmq

def main():

    try:
        context = zmq.Context(1)
        # Socket facing clients
        frontend = context.socket(zmq.PULL)
        frontend.setsockopt(zmq.LINGER,-1)
        frontend.bind("tcp://*:8880")

        # Socket facing services
        backend = context.socket(zmq.PUSH)
        backend.setsockopt(zmq.LINGER,-1)
        backend.bind("tcp://*:8888")

        dev = zmq.device(zmq.STREAMER, frontend, backend)
        dev.daemon = False
    except Exception, e:
        print e
        print "bringing down zmq device"
    finally:
        pass
        frontend.close()
        backend.close()
        context.term()

if __name__ == "__main__":
    main()