-
Notifications
You must be signed in to change notification settings - Fork 516
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
allow forwarded messages to use existing connections and the outbound queue #631
allow forwarded messages to use existing connections and the outbound queue #631
Conversation
Signed-off-by: Sam Curren <[email protected]>
Signed-off-by: Sam Curren <[email protected]>
Signed-off-by: Sam Curren <[email protected]>
Signed-off-by: Sam Curren <[email protected]>
Codecov Report
@@ Coverage Diff @@
## master #631 +/- ##
=======================================
Coverage 96.85% 96.85%
=======================================
Files 248 248
Lines 13260 13264 +4
=======================================
+ Hits 12843 12847 +4
Misses 417 417 |
await responder.send(packed, connection_id=recipient.connection_id) | ||
await responder.send( | ||
packed, | ||
connection_id=recipient.connection_id, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looking at the responder code, I think you can pass connection_targets
as target_list
, instead of passing connection_id
, and it would avoid the need to look up the connection information twice.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I needed to pass connection_id as well, but it accepted both. Updated.
Signed-off-by: Sam Curren <[email protected]>
@andrewwhitehead -- good to go? This should be it for 0.5.4, I think. |
This adjustment allows the mediator forward function to work with endpoint-less connections, either via active connections with return route, or via the outbound queue. (Sending to an endpoint was already supported.)