[zeromq-dev] Clean shutdown of PUSH/PULL pipeline inproc

Pieter Hintjens ph at imatix.com
Mon Mar 4 09:45:59 CET 2013

Send N "STOP" messages, and when the sink has received N STOP
messages, it knows each worker has finished.


On Sun, Mar 3, 2013 at 12:00 AM, Gerrit Hendrikus van Doorn
<g.h.vandoorn at gmail.com> wrote:
> Hi,
> I have a pipeline that uses inproc to pass messages to workers.
> client PUSH => [worker N*PULLL=> N*processing => worker N*PUSH] => sink PULL
> Not all messages send to the workers will also end up at the sink (by
> design!)/
> This works nicely but when the client is done sending messages, the pipeline
> might still be processing some of those messages. It is impossible for the
> sink or workers to know there are no more messages coming. What would be a
> good pattern to cleanly shut down the application when the pipeline is done
> processing?
> Thanks,
> Gerrit
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev

More information about the zeromq-dev mailing list