<div dir="ltr"><div><div><div><div>Hi Vince,<br><br></div>Sorry to not directly answer your question, but what's the actual problem you're trying to solve?<br><br></div>For example, what is limiting the subscriber from reading incoming messages as fast as they arrive, in your use case?<br></div>Cheers,<br></div>Aaron<br><div><div><div><div><div><div><br></div></div></div></div></div></div></div><div class="gmail_extra"><br><div class="gmail_quote">On 13 July 2016 at 18:09, vincegata <span dir="ltr"><<a href="mailto:vincegata@gmail.com" target="_blank">vincegata@gmail.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div dir="ltr">Hello All,<div><br></div><div>I cannot seem to be able to set up the high water mark for PUB/SUB.</div><div><br></div><div>My subscriber is expected sometimes to be somewhat slower than publisher</div><div>hence I want the publisher to drop the messages when subscriber is slow. I want</div><div>to set up the high water mark to, say, 2 messages, so when the subscriber is behind</div><div>for two messages then the publisher will start dropping them.</div><div><br></div><div>Can you take a look at my code. The publisher sends messages once every 200ms,</div><div>the subscriber reads messages once every second, the high water mark is set to 2.</div><div>Hence, I expect subscriber to receive approximately every fifth message. However,</div><div>my subscriber diligently reads all messages consequently and the publisher gets far </div><div>ahead. </div><div><br></div><div><a href="http://pastebin.com/2fv525ke" target="_blank">http://pastebin.com/2fv525ke</a><br></div><div><br></div><div>-- thank you!<br></div></div>
<br>_______________________________________________<br>
zeromq-dev mailing list<br>
<a href="mailto:zeromq-dev@lists.zeromq.org">zeromq-dev@lists.zeromq.org</a><br>
<a href="http://lists.zeromq.org/mailman/listinfo/zeromq-dev" rel="noreferrer" target="_blank">http://lists.zeromq.org/mailman/listinfo/zeromq-dev</a><br></blockquote></div><br></div>