[zeromq-dev] Python Streamer Push/Pull Device "losing" messages

James Thornton james at jamesthornton.com
Thu Oct 20 22:34:33 CEST 2011


Hello All -

Would you mind taking a look at this simple Python/PyZMQ Streamer?
(it's a simplified version of the one I posted in IRC today):

https://gist.github.com/1302163

When I run it, sometimes it will print that it receives all 1000
messages, sometimes it will be ~300, sometimes more or less -- it's so
intermittent as to how many messages it receives.

I'm using pyzmq 2.1.9 with ZMQ 2.1.4 on Fedora.

There are GBs of available memory, and as I understand it, a Streamer
PULL socket will receive as many messages as memory allows.

There is only 1 worker, and it receives the first 0 through X messages
so I know it's had time to spin up and connect.

However, I'm new to ZeroMQ so there may be something
simple/fundamental that I'm missing or not understanding.

Thanks.

- James



More information about the zeromq-dev mailing list