From 83b13778de83ca781ac42828d64af01de3d12841 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Fri, 10 Apr 2009 22:10:31 +0000 Subject: QPID-1791 : Replaced the get call before the dequeueAndDelete with a remove. So the remove call after the delete is now nolonger requried. Added manual test to assist identifing the problem git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@764079 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/txn/NonTransactionalContext.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) (limited to 'java/broker/src') diff --git a/java/broker/src/main/java/org/apache/qpid/server/txn/NonTransactionalContext.java b/java/broker/src/main/java/org/apache/qpid/server/txn/NonTransactionalContext.java index 2f27e1405a..9a90dd4bb2 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/txn/NonTransactionalContext.java +++ b/java/broker/src/main/java/org/apache/qpid/server/txn/NonTransactionalContext.java @@ -158,7 +158,7 @@ public class NonTransactionalContext implements TransactionalContext else { QueueEntry queueEntry; - queueEntry = unacknowledgedMessageMap.get(deliveryTag); + queueEntry = unacknowledgedMessageMap.remove(deliveryTag); if (debug) { @@ -187,9 +187,6 @@ public class NonTransactionalContext implements TransactionalContext // from the transaciton log queueEntry.dequeueAndDelete(_storeContext); - unacknowledgedMessageMap.remove(deliveryTag); - - } if(_inTran) { -- cgit v1.2.1