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/03/30 09:16:31 UTC

activemq git commit: [AMQ-6640] shrink test duration for ci boxes

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 <ga...@gmail.com>
Authored: Thu Mar 30 10:16:18 2017 +0100
Committer: gtully <ga...@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");