You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cm...@apache.org on 2009/06/22 21:07:44 UTC
svn commit: r787351 -
/activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java
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());
}
}
}