diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-04-10 22:10:31 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-04-10 22:10:31 +0000 |
| commit | 83b13778de83ca781ac42828d64af01de3d12841 (patch) | |
| tree | 449bcc91454562f8add0012a76ff7625d239cc0c /java/broker | |
| parent | 8457d581a12f8d13f1c330b8bbeef0d1a5006e74 (diff) | |
| download | qpid-python-83b13778de83ca781ac42828d64af01de3d12841.tar.gz | |
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
Diffstat (limited to 'java/broker')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/txn/NonTransactionalContext.java | 5 |
1 files changed, 1 insertions, 4 deletions
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) { |