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

[chirino]

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