From f982f86ceede56c2fa153e1cef21a31a75b5a669 Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Wed, 9 May 2012 09:32:55 +0000 Subject: QPID-3980: Last Value Queue: Replaced conflation queue entries are never deleted (entries remained acquired permanently) causing leak. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1336026 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/server/queue/ConflationQueueList.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) (limited to 'qpid/java/broker/src') diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConflationQueueList.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConflationQueueList.java index 6a2e4f155d..75e6f2cfdc 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConflationQueueList.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConflationQueueList.java @@ -79,10 +79,7 @@ public class ConflationQueueList extends SimpleQueueEntryList if(oldEntry.compareTo(entry) < 0) { // We replaced some other entry to become the newest value - if(oldEntry.acquire()) - { - discardEntry(oldEntry); - } + discardEntry(oldEntry); } else if (oldEntry.compareTo(entry) > 0) { -- cgit v1.2.1