activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmacn...@apache.org
Subject svn commit: r787351 - /activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java
Date Mon, 22 Jun 2009 19:07:44 GMT
Author: cmacnaug
Date: Mon Jun 22 19:07:44 2009
New Revision: 787351

URL: http://svn.apache.org/viewvc?rev=787351&view=rev
Log:
Fixing CursoredQueue Expirator infinite loop (caused by expired element not being removed
from the list)

Modified:
    activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java

Modified: activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java?rev=787351&r1=787350&r2=787351&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java
(original)
+++ activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java
Mon Jun 22 19:07:44 2009
@@ -1253,6 +1253,7 @@
                     for (QueueElement<V> qe : first.getValue()) {
                         qe.releaseSoftRef();
                         qe.acknowledge();
+                        expirationCache.remove(first.getKey());
                     }
                 }
             }



Mime
View raw message