-
Notifications
You must be signed in to change notification settings - Fork 8
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
RestBackend: Use real zmq subscription #277
base: main
Are you sure you want to change the base?
Conversation
Previously the code was only looking for subscriptions that matched exactly the topic of the message. Instead look through all subscriptions and find the ones that match the topic.
The previous implementation used the Request Socket to send a subscription mdp command instead of using the broker's pub/sub endpoint. Also the naming and usage of the different Sockets was inconsistent. This changes the socket types and uses the SUB socket for subscriptions while using the dealer socket for get requests.
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## main #277 +/- ##
==========================================
- Coverage 55.10% 55.08% -0.03%
==========================================
Files 68 68
Lines 7108 7111 +3
Branches 2640 2641 +1
==========================================
Hits 3917 3917
- Misses 1507 1509 +2
- Partials 1684 1685 +1
... and 3 files with indirect coverage changes Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. ☔ View full report in Codecov by Sentry. |
SonarCloud Quality Gate failed. 0 Bugs No Coverage information Catch issues before they fail your Quality Gate with our IDE extension SonarLint |
The current implementation uses the Request Socket to send a subscription mdp command instead of using the broker's pub/sub endpoint. Also the naming and usage of the different Sockets is inconsistent.
This changes the socket types and uses the SUB socket for subscriptions while using the dealer socket for get requests.
This might be incomplete and not handle every case and is not meant to be merged without further testing and discussion.