[zeromq-dev] Does the HWM work on PULL sockets?
Henry.Baragar at instantiated.ca
Fri May 27 18:40:14 CEST 2011
I am doing some experiments on 0MQ (using the ruby bindings) and have found
that the HWM does not seem to have any effect.
Here is my scenario:
I have a manager process that sends out a message every second on a PUSH
socket over a period of 10 seconds
I have a worker process with a HWM of of 1 that receives messages and takes 5
seconds to process each message (i.e. sleep 5)
I start the manager process which blocks until I start worker process. As
soon as the worker connects, the manager starts sending out its messages every
second: it does not block after sending out the 2nd message (nor the 3rd, 4th,
5th, etc.). Furthermore, if I kill the worker after the manager has sent out
7 messages and then start a new one, messages 2-7 get lost (message 1 has been
processed): I would expect only message 2, and possibly message 3, to be lost.
Am I understanding HWM correctly? Or is there a problem with HWM on PULL
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the zeromq-dev