svn commit: r787351 - /activemq/sandbox/activemq-flow/activemq-queue/src/main/java/org/apache/activemq/queue/CursoredQueue.java

[cmacnaug]

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());
                     }
                 }
             }