Send N "STOP" messages, and when the sink has received N STOP messages, it knows each worker has finished.
-Pieter On Sun, Mar 3, 2013 at 12:00 AM, Gerrit Hendrikus van Doorn <[email protected]> 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 > [email protected] > http://lists.zeromq.org/mailman/listinfo/zeromq-dev > _______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
