This closes #1439

2017-08-03 11:41:58 -04:00 · 2017-08-03 11:41:58 -04:00 · 64783c2504
parent c5c61f39eb dfb181a8b2
commit 64783c2504
1 changed files with 3 additions and 2 deletions
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
@ -298,8 +298,9 @@ public class AMQConsumer {
         }
      }
      if (ack.isExpiredAck()) {
-         //adjust delivering count for expired messages
-         this.serverConsumer.getQueue().decDelivering(ackList.size());
+         for (MessageReference ref : ackList) {
+            ref.getQueue().expire(ref);
+         }
      }
   }