diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
index 5eebde2549..f04a7c695b 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java
@@ -260,7 +260,7 @@ public class KahaDBStore extends MessageDatabase implements PersistenceAdapter {
                 });
             }
             if( location!=null ) {
-                cursorPos=location;
+                cursorPos=location+1;
             }
             
         }
diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
index 145904b550..11a98d694d 100644
--- a/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorKahaDBNoDuplicateTest.java
@@ -29,11 +29,6 @@ import org.apache.activemq.store.kahadb.KahaDBStore;
  **/
 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();