activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r741334 - in /activemq/trunk/activemq-core/src: main/java/org/apache/activemq/store/kahadb/KahaDBStore.java test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
Date Thu, 05 Feb 2009 22:46:01 GMT
Author: chirino
Date: Thu Feb  5 22:46:01 2009
New Revision: 741334

URL: http://svn.apache.org/viewvc?rev=741334&view=rev
Log:
Fixed StoreQueueCursorKahaDBNoDuplicateTest

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java?rev=741334&r1=741333&r2=741334&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
Thu Feb  5 22:46:01 2009
@@ -260,7 +260,7 @@
                 });
             }
             if( location!=null ) {
-                cursorPos=location;
+                cursorPos=location+1;
             }
             
         }

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java?rev=741334&r1=741333&r2=741334&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
Thu Feb  5 22:46:01 2009
@@ -30,11 +30,6 @@
 public class StoreQueueCursorKahaDBNoDuplicateTest extends StoreQueueCursorNoDuplicateTest
{
 
     @Override
-    public void testNoDuplicateAfterCacheFullAndReadPast() throws Exception {
-        // TODO - check out how best to implement setBatch on the store
-    }
-    
-    @Override
     protected BrokerService createBroker() throws Exception {
         BrokerService broker = super.createBroker();
         PersistenceAdapter persistenceAdapter = new KahaDBStore();



Mime
View raw message