Repository: activemq Updated Branches: refs/heads/master d84a58656 -> 5ac9657c1
[AMQ-6640] shrink test duration for ci boxes Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/5ac9657c Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/5ac9657c Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/5ac9657c Branch: refs/heads/master Commit: 5ac9657c123993e7f4bac16ed79e2c9763ea45d1 Parents: d84a586 Author: gtully <gary.tu...@gmail.com> Authored: Thu Mar 30 10:16:18 2017 +0100 Committer: gtully <gary.tu...@gmail.com> Committed: Thu Mar 30 10:16:18 2017 +0100 ---------------------------------------------------------------------- .../org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/5ac9657c/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java index b34b67e..8abb530 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java @@ -107,7 +107,7 @@ public class DuplexAdvisoryRaceTest { Subscription subscription = super.addConsumer(context, info); // delay return to allow dispatch to interleave if (context.isNetworkConnection()) { - TimeUnit.MILLISECONDS.sleep(300); + TimeUnit.MILLISECONDS.sleep(200); } return subscription; }; @@ -126,7 +126,7 @@ public class DuplexAdvisoryRaceTest { + "?jms.watchTopicAdvisories=false"); // populate dests - final int numDests = 800; + final int numDests = 400; final int numMessagesPerDest = 50; final int numConsumersPerDest = 5; populate(brokerAFactory, 0, numDests/2, numMessagesPerDest); @@ -148,7 +148,7 @@ public class DuplexAdvisoryRaceTest { LOG.info("received: " + responseReceived.get()); return responseReceived.get() >= numMessagesPerDest * numDests; } - }, 5*60*1000)) { + }, 10*60*1000)) { org.apache.activemq.TestSupport.dumpAllThreads("DD");