ZMQ Poller that uses ZMQStream and Torndado's ioloop for handling poll events on ZMQ sockets
Python
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
README.md
zmq-stream-poller.py
zmq-stream-poller.pyc

README.md

zmq-poller-with-zmq-stream-tornado-ioloop

ZMQ Poller that uses ZMQStream and Torndado's ioloop for handling poll events on ZMQ sockets


This poller uses ZMQStream to handle polling events from ZeroMQ sockets. This also enables usage of callbacks to send & receive data. There's a push server that sends out "Continue" or "Stop" messages which the worker client reads and uses to continue work or not.


To run: python zmq-stream-poller.py