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

Take credits for inactive stream subscription #7638

Merged

Conversation

acogoluegnes
Copy link
Contributor

Not taking the credits can starve the subscription, making it permanently under its credit send limit.

The subscription then never dispatches messages when it becomes active again.

This happens in an active-inactive-active cycle, especially with slow consumers.

Not taking the credits can starve the subscription,
making it permanently under its credit send limit.

The subscription then never dispatches messages when
it becomes active again.

This happens in an active-inactive-active cycle, especially
with slow consumers.
@acogoluegnes acogoluegnes marked this pull request as ready for review March 16, 2023 11:03
@kjnilsson kjnilsson self-requested a review March 16, 2023 12:04
@acogoluegnes acogoluegnes merged commit 3f74df7 into main Mar 16, 2023
@acogoluegnes acogoluegnes deleted the stream-take-credit-even-for-inactive-subscription branch March 16, 2023 12:14
acogoluegnes added a commit that referenced this pull request Mar 16, 2023
Take credits for inactive stream subscription (backport #7638)
acogoluegnes added a commit to rabbitmq/rabbitmq-stream-java-client that referenced this pull request Mar 16, 2023
No new messages could arrive because of credit starvation,
as credit providing request were not taking into
account for inactive subscription.

This tests a server-side fix. The test is disabled for now.

References rabbitmq/rabbitmq-server#7638
acogoluegnes added a commit that referenced this pull request Mar 16, 2023
Take credits for inactive stream subscription (backport #7638) (backport #7641)
github-actions bot pushed a commit to rabbitmq/rabbitmq-stream-java-client that referenced this pull request Mar 16, 2023
No new messages could arrive because of credit starvation,
as credit providing request were not taking into
account for inactive subscription.

This tests a server-side fix. The test is disabled for now.

References rabbitmq/rabbitmq-server#7638
@michaelklishin michaelklishin added this to the 3.11.11 milestone Mar 17, 2023
acogoluegnes added a commit to rabbitmq/rabbitmq-stream-java-client that referenced this pull request Mar 23, 2023
github-actions bot pushed a commit to rabbitmq/rabbitmq-stream-java-client that referenced this pull request Mar 23, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants