diff --git a/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java b/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java index 242524472c..c4e216690b 100644 --- a/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java @@ -48,7 +48,6 @@ public class PListTest { final Vector exceptions = new Vector(); ExecutorService executor; - @Test public void testAddLast() throws Exception { final int COUNT = 1000; @@ -147,7 +146,6 @@ public class PListTest { assertFalse(plist.remove("doesNotExist")); } - @Test public void testRemoveSingleEntry() throws Exception { plist.addLast("First", new ByteSequence("A".getBytes())); @@ -169,7 +167,6 @@ public class PListTest { assertFalse(plist.remove(0)); } - @Test public void testConcurrentAddRemove() throws Exception { File directory = store.getDirectory(); @@ -260,7 +257,6 @@ public class PListTest { assertTrue("finished ok", finishedInTime); } - @Test public void testConcurrentAddLast() throws Exception { File directory = store.getDirectory(); @@ -310,7 +306,6 @@ public class PListTest { LOG.info("After remove index file: " + store.pageFile.getFile().length()); } - @Test public void testConcurrentAddRemoveWithPreload() throws Exception { File directory = store.getDirectory(); @@ -442,40 +437,6 @@ public class PListTest { assertTrue("test did not timeout ", shutdown); } - @Test - public void testSerialAddIterate() throws Exception { - File directory = store.getDirectory(); - store.stop(); - IOHelper.mkdirs(directory); - IOHelper.deleteChildren(directory); - store = new PListStore(); - store.setIndexPageSize(512); - store.setJournalMaxFileLength(100*1024); - store.setDirectory(directory); - store.setCleanupInterval(-1); - store.setIndexEnablePageCaching(false); - store.setIndexWriteBatchSize(2000); - store.setEnableIndexWriteAsync(false); - store.start(); - - final int iterations = 1000; - final int numLists = 1; - - LOG.info("create"); - for (int i=0; i