activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject [2/3] git commit: speed up this test and improve logging in the event of failure
Date Wed, 19 Mar 2014 15:34:43 GMT
speed up this test and improve logging in the event of failure


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2efb6df6
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2efb6df6
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2efb6df6

Branch: refs/heads/trunk
Commit: 2efb6df6197e87743f8ef2c8e22fbbb1851b162c
Parents: 89446c7
Author: gtully <gary.tully@gmail.com>
Authored: Wed Mar 19 15:32:10 2014 +0000
Committer: gtully <gary.tully@gmail.com>
Committed: Wed Mar 19 15:32:10 2014 +0000

----------------------------------------------------------------------
 .../usecases/DurableSubSelectorDelayWithRestartTest.java         | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/2efb6df6/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DurableSubSelectorDelayWithRestartTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DurableSubSelectorDelayWithRestartTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DurableSubSelectorDelayWithRestartTest.java
index 1bfd52e..5e1cb42 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DurableSubSelectorDelayWithRestartTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DurableSubSelectorDelayWithRestartTest.java
@@ -83,10 +83,11 @@ public class DurableSubSelectorDelayWithRestartTest {
         }
 
         final KahaDBPersistenceAdapter pa = (KahaDBPersistenceAdapter) broker.getPersistenceAdapter();
-        assertTrue("only one journal file should be left ", Wait.waitFor(new Wait.Condition()
{
+        assertTrue("small number of journal files should be left ", Wait.waitFor(new Wait.Condition()
{
 
             @Override
             public boolean isSatisified() throws Exception {
+                LOG.info("journal data file count - expected {} actual {}", 4, pa.getStore().getJournal().getFileMap().size());
                 return pa.getStore().getJournal().getFileMap().size() < 4;
             }
         }, TimeUnit.MINUTES.toMillis(3)));
@@ -299,6 +300,7 @@ public class DurableSubSelectorDelayWithRestartTest {
         KahaDBPersistenceAdapter kahadb = new KahaDBPersistenceAdapter();
         kahadb.setDirectory(kahadbData);
         kahadb.setJournalMaxFileLength(  10 * 1024);
+        kahadb.setCleanupInterval(5000);
         broker.setPersistenceAdapter(kahadb);
 
         broker.addConnector("tcp://localhost:61656");


Mime
View raw message