From d89a3020411098e24c8f5018b0f5c01882a3d264 Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Thu, 5 Feb 2009 22:46:01 +0000 Subject: [PATCH] Fixed StoreQueueCursorKahaDBNoDuplicateTest git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741334 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/store/kahadb/KahaDBStore.java | 2 +- .../cursors/StoreQueueCursorKahaDBNoDuplicateTest.java | 5 ----- 2 files changed, 1 insertion(+), 6 deletions(-) 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();