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 <[email protected]> Authored: Wed May 4 16:15:55 2016 +0100 Committer: gtully <[email protected]> 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();
