aop
aop copied to clipboard
streamnative
Fix - Add permit if receive nack command.
Motivation
Add permit if receive nack command.
The availablePermits will reduce when resend message to consumer.
Modifications
Verifying this change
Does this pull request potentially affect one of the following parts:
If yes was chosen, please highlight the changes
- Dependencies (does it add or upgrade a dependency): (no)
- The public API: (no)
- The schema: (no)
- The default values of configurations: (no)
- The wire protocol: (no)
- The rest endpoints: (no)
- The admin cli options: (no)
- Anything that affects deployment: (no)
Documentation
Check the box below and label this PR (if you have committer privilege).
Need to update docs?
- [x]
no-need-doc
Please take a look. @gaoran10 @mingyifei
availablePermits are processed at the time of consumption.
availablePermits are processed at the time of consumption.
CreditManager done not work.
You can try it.
When consumer client send nack command, broker will resend message and decrease availablePermits, after 1000 times sended, will blocked.
@mingyifei
availablePermits are processed at the time of consumption.
CreditManager done not work.
You can try it. When consumer client send nack command, broker will resend message and decrease
availablePermits, after 1000 times sended, will blocked. @mingyifei
ok, you can test the multi-bundle implementation, the previous version will be deprecated in the future.
availablePermits are processed at the time of consumption.
CreditManager done not work.
You can try it. When consumer client send nack command, broker will resend message and decrease
availablePermits, after 1000 times sended, will blocked. @mingyifei
AmqpMultiBundlesChannel