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

[Gerrit Hendrikus van Doorn]

When sending N STOP messages through a pipeline, these messages might be
received at the SINK before the other messages have been processed by the
workers.

Another (but not ideal) method  is to have every worker send every message
to the SINK. The client, when finished, can publish (using a PUB socket)
the total number of messages it send to the SINK, which then counts the
number of received messages and exits when the total number is reached.
Before exiting it would notify the workers using another PUB/SUB
combination.
The downside of this construct is that every message that a worker received
has to be passed on to the SINK.

- Gerrit
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20130304/df0fb177/attachment.htm>