From 4d6043aa94227b4b2604394e0c855c9869c211f4 Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Wed, 1 Oct 2008 12:01:00 +0000 Subject: [PATCH] fix regression AMQ-1959 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@700746 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/activemq/ActiveMQMessageConsumer.java | 1 + 1 file changed, 1 insertion(+) diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java index adf22aa8db..fda09f542b 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java @@ -880,6 +880,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC ack.setTransactionId(session.getTransactionContext().getTransactionId()); } session.sendAck(ack); + pendingAck = null; // Adjust the counters deliveredCounter -= deliveredMessages.size();