diff --git a/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/MasterLevelDBStoreTest.java b/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/MasterLevelDBStoreTest.java index b639902b0e..645da028f3 100644 --- a/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/MasterLevelDBStoreTest.java +++ b/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/MasterLevelDBStoreTest.java @@ -95,7 +95,7 @@ public class MasterLevelDBStoreTest { public void stop() throws Exception { if (store.isStarted()) { store.stop(); + FileUtils.deleteDirectory(store.directory()); } - FileUtils.deleteDirectory(store.directory()); } } diff --git a/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ReplicatedLevelDBBrokerTest.java b/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ReplicatedLevelDBBrokerTest.java index 7a38315bdd..3514930cdc 100644 --- a/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ReplicatedLevelDBBrokerTest.java +++ b/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ReplicatedLevelDBBrokerTest.java @@ -43,6 +43,9 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; import org.apache.commons.io.FileUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import static org.junit.Assert.*; @@ -51,6 +54,7 @@ import static org.junit.Assert.*; */ public class ReplicatedLevelDBBrokerTest extends ZooKeeperTestSupport { + protected static final Logger LOG = LoggerFactory.getLogger(ReplicatedLevelDBBrokerTest.class); final SynchronousQueue masterQueue = new SynchronousQueue(); ArrayList brokers = new ArrayList(); @@ -70,6 +74,7 @@ public class ReplicatedLevelDBBrokerTest extends ZooKeeperTestSupport { @Test(timeout = 1000*60*10) public void testAMQ4837viaJMX() throws Throwable { for (int i = 0; i < 2; i++) { + LOG.info("testAMQ4837viaJMX - Iteration: " + i); resetDataDirs(); testAMQ4837(true); stopBrokers(); @@ -442,6 +447,7 @@ public class ReplicatedLevelDBBrokerTest extends ZooKeeperTestSupport { store.setContainer(id); store.setReplicas(3); store.setZkAddress("localhost:" + connector.getLocalPort()); + store.setZkSessionTmeout("15s"); store.setHostname("localhost"); store.setBind("tcp://0.0.0.0:0"); return store; diff --git a/activemq-leveldb-store/src/test/resources/log4j.properties b/activemq-leveldb-store/src/test/resources/log4j.properties index 661669a6df..06743dc44b 100755 --- a/activemq-leveldb-store/src/test/resources/log4j.properties +++ b/activemq-leveldb-store/src/test/resources/log4j.properties @@ -21,11 +21,12 @@ log4j.rootLogger=INFO, console, file log4j.logger.org.apache.activemq=INFO log4j.logger.org.apache.activemq.leveldb=DEBUG +log4j.logger.org.apache.zookeeper=DEBUG # Console will only display warnnings log4j.appender.console=org.apache.log4j.ConsoleAppender log4j.appender.console.layout=org.apache.log4j.PatternLayout -log4j.appender.console.layout.ConversionPattern=%-5p | %t | %m%n +log4j.appender.console.layout.ConversionPattern=%d | %-5p | %t | %m%n log4j.appender.console.threshold=DEBUG # File appender will contain all info messages diff --git a/pom.xml b/pom.xml index 085ae8ce64..dca93f8a9a 100755 --- a/pom.xml +++ b/pom.xml @@ -100,7 +100,7 @@ 1.1.2 0.4.0 1.4.0 - 3.4.5 + 3.4.6 0.8 0.30 1.3