activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r564685 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
Date Fri, 10 Aug 2007 17:18:15 GMT
Author: chirino
Date: Fri Aug 10 10:18:14 2007
New Revision: 564685

URL: http://svn.apache.org/viewvc?view=rev&rev=564685
Log:
Fix for the testQueuePersistentUncommitedAcksLostOnRestart() test in RecoveryBrokerTest. 
Since this test resuses the memory based store instance across restarts, the cusror pointers
were not getting reset after restart.


Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java?view=diff&rev=564685&r1=564684&r2=564685
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java
Fri Aug 10 10:18:14 2007
@@ -56,6 +56,7 @@
     }
 
     public void start() throws Exception {
+        store.resetBatching();
     }
 
     public void stop() throws Exception {



Mime
View raw message