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/04 15:16:19 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-5603 -
don't async preallocate to keep match data file count
Repository: activemq
Updated Branches:
refs/heads/master 555cd2b6b -> 231679d93
https://issues.apache.org/jira/browse/AMQ-5603 - don't async preallocate to keep match data file count
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/231679d9
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/231679d9
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/231679d9
Branch: refs/heads/master
Commit: 231679d936e986a00930a96cc859b0a5b6d77486
Parents: 555cd2b
Author: gtully <ga...@gmail.com>
Authored: Wed May 4 16:15:55 2016 +0100
Committer: gtully <ga...@gmail.com>
Committed: Wed May 4 16:15:55 2016 +0100
----------------------------------------------------------------------
.../src/test/java/org/apache/activemq/bugs/AMQ4212Test.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/231679d9/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4212Test.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4212Test.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4212Test.java
index 1d34174..953eb8e 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4212Test.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ4212Test.java
@@ -41,6 +41,7 @@ import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
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.Before;
@@ -79,6 +80,7 @@ public class AMQ4212Test {
pa.setCheckpointInterval(TimeUnit.SECONDS.toMillis(5));
pa.setCleanupInterval(TimeUnit.SECONDS.toMillis(5));
pa.setForceRecoverIndex(recover);
+ pa.setPreallocationScope(Journal.PreallocationScope.ENTIRE_JOURNAL.name());
service.setPersistenceAdapter(pa);
service.start();