You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2021/03/25 11:52:13 UTC

[activemq] branch activemq-5.15.x updated: AMQ-8190 add wait time & shrink duration for CI test run

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/activemq-5.15.x by this push:
     new 55fa79f  AMQ-8190 add wait time & shrink duration for CI test run
55fa79f is described below

commit 55fa79f555e6837bf0a9317a2035d462152b893c
Author: Charlie Chen <ch...@amazon.com>
AuthorDate: Wed Mar 24 12:56:35 2021 -0700

    AMQ-8190 add wait time & shrink duration for CI test run
    
    (cherry picked from commit 6691e23e4835cdf8b20b30cc0a580d822feed5f6)
---
 .../java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 8abb530..9196311 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(200);
+                    TimeUnit.MILLISECONDS.sleep(100);
                 }
                 return subscription;
             };
@@ -148,7 +148,7 @@ public class DuplexAdvisoryRaceTest {
                 LOG.info("received: " + responseReceived.get());
                 return responseReceived.get() >= numMessagesPerDest * numDests;
             }
-        }, 10*60*1000)) {
+        }, 30*60*1000)) {
 
            org.apache.activemq.TestSupport.dumpAllThreads("DD");