Please use this template for reporting suspected bugs or requests for help.
Here are 2 python files:
# pub.py import zmq import time c = zmq.Context.instance() s = c.socket(zmq.PUB) s.bind('ipc:///tmp/socket') time.sleep(10) # helps to run 2 processes simultaneously s.send(b'42')
# sub.py import zmq c = zmq.Context.instance() s = c.socket(zmq.SUB) s.subscribe('') s.connect('ipc:///tmp/socket') while True: print(s.recv())
To reproduce the issue:
sub.py
pub.py
sub.py received only one message (expected), but subsequent calls to pub.py will not cause sub.py to receive anything.
sub.py should notice that previously connected socket is closed, reconnect, and be able to receive messages from subsequent pub.py .
Metadata
Metadata
Assignees
Labels
Type
Projects
Milestone
Relationships
Development
Issue actions