You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2016/05/03 12:36:53 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5603 -
one more journal in the mix for this test with async preallocation
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 <ga...@gmail.com>
Authored: Tue May 3 11:36:47 2016 +0100
Committer: gtully <ga...@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) {