ActiveMQ INDIVIDUAL_ACKNOWLEDGE mode does not respect prefetchSize on Durable Topic Subscription
Issue
We are upgrading from ActiveMQ 5.5.1 to Fuse 6.1/ActiveMQ 5.9.0. We have an use case that requires Individual Acknowledgement of messages on a Durable Topic Subscription.
In ActiveMQ 5.5.1, individual acknowledgement mode respected prefetch limit: if a client had pulled down messages equal to the prefetchSize, it would not pull another message down until one of those messages had been acknowledged (ack() method called).
In ActiveMQ 5.9.0, prefetchSize seems to be ignored: MessageCountAwaitingAcknowledge and DispatchedQueueSize grow without respecting prefetch limit. Under working conditions, MessageCountAwaitingAcknowledge and DispatchedQueueSize go up together until PrefetchSize is reached. Then, PendingQueueSize starts to go up. In ActiveMQ 5.9.0, Individual Acknowledge mode for durable subscription to topic, MessageCountAwaitingAcknowledge and DispacthcedQueueSize go up all the time without respecting to prefetchSize and PendingQueueSize never goes up.
Environment
- JBoss Fuse 6.1
- JBoss A-MQ 6.1
- ActiveMQ 5.9
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase of over 48,000 articles and solutions.
Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.
