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

reconnect #143

Open
youngday opened this issue Sep 24, 2021 · 3 comments
Open

reconnect #143

youngday opened this issue Sep 24, 2021 · 3 comments

Comments

@youngday
Copy link
Contributor

we need reconnect function ,"cetra3/tmq" from github have reconnect function ,if we can merge it, waiting for your good news!

@Alexei-Kornienko
Copy link
Collaborator

We cannot merge it directly cause it has a completely different code structure. However we can think about similar implementation. I've already looked at this problem before however I don't have a lot of time to work on this feature. I'll try to take a look on a weekend

@dimitar-petrov
Copy link
Contributor

Can I help with this feature?

@Alexei-Kornienko
Copy link
Collaborator

@dimitar-petrov sure. However for this feature I don't have a clear implementation plan at the moment.
I only have some general ideas about how this is supposed to work:

  1. We would have to add some flag active_side - for the side that is responsible for reconnecting (Cause right now there is no difference between server and client after handshake).
  2. Active client would have to store a list of endpoints that he is connected to
  3. If certain TcpStream disconnects for whatever reason client should try to connect again in some kind of loop

So this is a general overview but we'll have to work on actual details and see how it fit's existing code structure

Alexei-Kornienko added a commit that referenced this issue Jan 8, 2022
Initial prototype is working for GenericSocketBackend
TODO:
* implement for rest of the sockets
* implement outgoing queue for messages according to ZMQ spec

Related to #143
bemyak pushed a commit to bemyak/zmq.rs that referenced this issue May 14, 2024
Initial prototype is working for GenericSocketBackend
TODO:
* implement for rest of the sockets
* implement outgoing queue for messages according to ZMQ spec

Related to zeromq#143
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