-
Notifications
You must be signed in to change notification settings - Fork 190
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
630: Only nack messages upon cancellation of a consumer subscription … #634
630: Only nack messages upon cancellation of a consumer subscription … #634
Conversation
…that belong to that consumer subscription.
Closes #630 |
Took awhile due to illness, vacation and other priorities. It also wasn't easy to find a proper, simple regression test, but I think I found one! Following TDD: The test was giving the expected exception before fixing the code. After fixing the code, the test succeeded. |
@@ -1587,6 +1587,141 @@ async def test_heartbeat_disabling( | |||
async with connection: | |||
assert heartbeat == 0 | |||
|
|||
async def test_non_acked_messages_are_redelivered_to_queue( |
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.
Test to see if messages are properly nack'ed and I didn't break anything.
# Cleanup, delete the queue | ||
await queue.delete() | ||
|
||
async def test_regression_only_messages_cancelled_subscription_are_nacked( |
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.
Regression test which failed before fixing the code. Documentation is inline to show why the test is constructed the way it is.
@lfse-slafleur released as 9.4.2 |
…that belong to that consumer subscription.