Description
I discovered an issue where the Inflight message size counter is not decremented properly if a Prefetch consumer (durable or queue) expires the message and sends an expiration ack back to the broker. The issue is simply the original commit for this feature missed that location to decrement the size when the message was removed from dispatch.
This Jira will fix that issue and will also clean up the handling of inflight message size and count inside of PrefetchSubscription to be a little cleaner, easier to follow and less error prone.
Attachments
Issue Links
- is caused by
-
AMQ-5837 Add inflight message size to SubscriptionStatistics
-
- Resolved
-