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 2017/10/25 12:08:16 UTC
activemq git commit: [no jira] calm this test a bit due to oom in ci
builds
Repository: activemq
Updated Branches:
refs/heads/master 489cdc624 -> be6f4b69c
[no jira] calm this test a bit due to oom in ci builds
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/be6f4b69
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/be6f4b69
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/be6f4b69
Branch: refs/heads/master
Commit: be6f4b69c12b8f52ce59d5c97150f10da0cd264d
Parents: 489cdc6
Author: gtully <ga...@gmail.com>
Authored: Wed Oct 25 13:08:00 2017 +0100
Committer: gtully <ga...@gmail.com>
Committed: Wed Oct 25 13:08:00 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/activemq/bugs/DuplicateFromStoreTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/be6f4b69/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/DuplicateFromStoreTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/DuplicateFromStoreTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/DuplicateFromStoreTest.java
index 4f4004c..5854fc7 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/DuplicateFromStoreTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/DuplicateFromStoreTest.java
@@ -58,7 +58,7 @@ public class DuplicateFromStoreTest {
protected final static int NUM_PRODUCERS = 100;
protected final static int NUM_CONSUMERS = 20;
- protected final static int NUM_MSGS = 40000;
+ protected final static int NUM_MSGS = 20000;
protected final static int CONSUMER_SLEEP = 0;
protected final static int PRODUCER_SLEEP = 10;
@@ -85,6 +85,7 @@ public class DuplicateFromStoreTest {
policy.setMemoryLimit(10 * 1024 * 1024); // 10 MB
policy.setExpireMessagesPeriod(0);
policy.setEnableAudit(false); // allow any duplicates from the store to bubble up to the q impl
+ policy.setQueuePrefetch(100);
PolicyMap policies = new PolicyMap();
policies.put(dest, policy);
broker.setDestinationPolicy(policies);