fix and tests for: https://issues.apache.org/jira/browse/AMQ-4083
Revert previous fix. We need to ack each expired message when we detect and not overload the usage of delivered acks for extending the prefetch window. The problem was an edge case where the broker detected a message as expired after the client had delivered it but before it ack'd it as consumed.
|
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java