activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-5603 - one more journal in the mix for this test with async preallocation
Date Tue, 03 May 2016 10:36:53 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 27799fec9 -> 4f43a2121


https://issues.apache.org/jira/browse/AMQ-5603 - one more journal in the mix for this test
with async preallocation


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

Branch: refs/heads/master
Commit: 4f43a2121264152b09166b8a09403ee0c205233d
Parents: 27799fe
Author: gtully <gary.tully@gmail.com>
Authored: Tue May 3 11:36:47 2016 +0100
Committer: gtully <gary.tully@gmail.com>
Committed: Tue May 3 11:36:47 2016 +0100

----------------------------------------------------------------------
 .../src/test/java/org/apache/activemq/bugs/AMQ2832Test.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/4f43a212/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2832Test.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2832Test.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2832Test.java
index 1b3a4e5..c2e3895 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2832Test.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2832Test.java
@@ -46,6 +46,7 @@ import org.apache.activemq.leveldb.LevelDBStore;
 import org.apache.activemq.store.PersistenceAdapter;
 import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
 import org.apache.activemq.store.kahadb.disk.journal.DataFile;
+import org.apache.activemq.store.kahadb.disk.journal.Journal;
 import org.apache.activemq.util.Wait;
 import org.junit.After;
 import org.junit.Test;
@@ -287,7 +288,7 @@ public class AMQ2832Test {
         assertTrue("Less than three journal file expected, was " + getNumberOfJournalFiles(),
Wait.waitFor(new Wait.Condition() {
             @Override
             public boolean isSatisified() throws Exception {
-                return getNumberOfJournalFiles() <= 3;
+                return getNumberOfJournalFiles() <= 4;
             }
         }, TimeUnit.MINUTES.toMillis(3)));
 
@@ -302,6 +303,7 @@ public class AMQ2832Test {
 
         Collection<DataFile> files =
             ((KahaDBPersistenceAdapter) broker.getPersistenceAdapter()).getStore().getJournal().getFileMap().values();
+        LOG.info("Data files: " + files);
         int reality = 0;
         for (DataFile file : files) {
             if (file != null) {


Mime
View raw message