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

[Gerrit Hendrikus van Doorn]

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
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20130302/834af85a/attachment.htm>