You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This question is related to the Paranoid Pirate Pattern sample project:
Is it by intention that the Paranoid Pirate Pattern is not supposed to recover from a restart of the Queue component or is this an error of the sample implementation (or even NetMQ core) which needs to be fixed?
Steps to reproduce:
start queue
start a worker
start a client
stop queue
wait for a timeout message of worker and/or client printed to console
restart queue
After these steps messages from clients wont be processed anymore despite all components (queue + worker + client) are up and running again after step 6.
The text was updated successfully, but these errors were encountered:
On every (heartbeat-) timeout inside the worker it will completely dispose the DealerSocket and then create a new one. But for this newly created DealerSocket the event wireup for ReceiveReady is missing. This way the new DealerSocket won't react to any incoming messages.
For reproduction of the actual error I would recommend to disable the "crash simulation" inside the worker component. This simulation will most probably fire before one is able to see the actual error which I am addressing with this issue / pull request.
This question is related to the Paranoid Pirate Pattern sample project:
Is it by intention that the Paranoid Pirate Pattern is not supposed to recover from a restart of the Queue component or is this an error of the sample implementation (or even NetMQ core) which needs to be fixed?
Steps to reproduce:
After these steps messages from clients wont be processed anymore despite all components (queue + worker + client) are up and running again after step 6.
The text was updated successfully, but these errors were encountered: