-
Notifications
You must be signed in to change notification settings - Fork 29
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
Request Response Subscription manager #351
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## 311ProtocolAdapter #351 +/- ##
======================================================
+ Coverage 82.86% 83.19% +0.32%
======================================================
Files 23 24 +1
Lines 9269 9492 +223
======================================================
+ Hits 7681 7897 +216
- Misses 1588 1595 +7 ☔ View full report in Codecov by Sentry. |
Just a random thought but would there be any value in adding an 'unsubscribe to all' function that can be called prior to destruction? The unsubscribes would be sent to the mqtt client to be processed (or not processed if the client is also being destroyed) to free up whatever subscriptions the RR had. Would be fire and forget with no wait on acks. This may be useful in a use-case where someone is creating and destroying multiple rr clients over the course of a connection with different names. |
@@ -481,6 +481,32 @@ add_test_case(mqtt311_listener_connection_events_no_session) | |||
add_test_case(mqtt311_listener_connection_events_with_session) | |||
add_test_case(mqtt311_listener_publish_event) | |||
|
|||
# "rrsm" = "request_response_subscription_manager" |
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.
Trivial: The aws_rr_subscription_manager_init()
would immediately return an AWS_ERROR_INVALID_ARGUMENT
error but should we still add a test that insures a max_subscriptions < 1 fails?
That's what |
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.