-
Notifications
You must be signed in to change notification settings - Fork 153
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
Not able to publish messages via 0MQ from backend server #47705
Comments
Hi, The SUB socket is tricky. Nothing will show up in the Pushpin logs unless there is at least one subscribing client. You also need to be careful about the general race condition with ZeroMQ PUB/SUB, which happens if you send too soon after connecting the SUB socket and you've not yet received subscriptions. For example, if you make a simple program that connects to Pushpin and immediately sends a message, it will likely be dropped. The SUB socket is better used by long-running programs. For short-running programs, you should publish via HTTP. If you just want to test sending to Pushpin's SUB socket from a short-running program, try inserting a delay after connecting but before sending a message. There's no need to do anything with the routes. You can have requests routed to an HTTP backend and still publish via ZeroMQ. |
Hi, |
That's correct. You could try using https://github.com/fanout/pushpin/blob/master/tools/monitorsubsock.py (requires python 2 and |
Hello @shreyasdn @jkarneges I am facing similar problem. Did it work for you ? Any resolution ? |
I have a setup where i have a docker image running the pushpin server and have used configuration from the sample file to configure the server. I am able to get and send messages via http but i am unable to publish back messages to the 0MQ SUB socket. Does the SUB socket also require routes file to have a 0MQ line? Can http and 0MQ be used together i.e. get message to backend via http and send message back to pushpin via 0MQ? I have posted the config used below. Also on the pushpin side i am unable to check if the message from the socket has reached, I have turned on the debug mode but am not able to see any activity.
The text was updated successfully, but these errors were encountered: