Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Queueing examples #51

Closed
maxfridbe opened this issue Apr 1, 2013 · 3 comments
Closed

Queueing examples #51

maxfridbe opened this issue Apr 1, 2013 · 3 comments

Comments

@maxfridbe
Copy link

Are there any examples of publisher sockets publishing and then a subscriber connecting after a delay and then dequeuing those messages. I tried setting pubSocket.Options.SendBuffer but the messages are lost.

What am I missing?

@tobi-tobsen
Copy link
Contributor

As the zmq guide indicates, the first subscriber will most likely miss messages even when using the much hated sleep(). Have you tried the synchronized pub/sub pattern described in the zmq guide: http://zguide.zeromq.org/page:all#toc47 instead?

maxfridbe notifications@github.com schrieb:

Are there any examples of publisher sockets publishing and then a
subscriber connecting after a delay and then dequeuing those messages.
I tried setting pubSocket.Options.SendBuffer but the
messages are lost.

What am I missing?


Reply to this email directly or view it on GitHub:
#51

Diese Nachricht wurde von meinem Android-Mobiltelefon mit K-9 Mail gesendet.

@somdoron
Copy link
Member

somdoron commented Apr 2, 2013

hi @tobi-tobsen ,

I didn't find a way to send you a private message, anyway I gave you maintainer permissions on the project, you can now merge pull requests (by the C4 process of course).

@tobi-tobsen
Copy link
Contributor

@somdoron Thanks a lot! I will read the C4 process again ;-)
@maxfridbe This picture (taken from the zmq guide) might also help to diagnose your problem:
fig25

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants