Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[AMQ-6640] shrink test duration for ci boxes

This commit is contained in:
gtully 2017-03-30 10:16:18 +01:00
parent d84a58656c
commit 5ac9657c12
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/DuplexAdvisoryRaceTest.java
View File

@ -107,7 +107,7 @@ public class DuplexAdvisoryRaceTest {
Subscription subscription = super.addConsumer(context, info); Subscription subscription = super.addConsumer(context, info);
// delay return to allow dispatch to interleave // delay return to allow dispatch to interleave
if (context.isNetworkConnection()) { if (context.isNetworkConnection()) {
TimeUnit.MILLISECONDS.sleep(300); TimeUnit.MILLISECONDS.sleep(200);
} }
return subscription; return subscription;
}; };
@ -126,7 +126,7 @@ public class DuplexAdvisoryRaceTest {
+ "?jms.watchTopicAdvisories=false"); + "?jms.watchTopicAdvisories=false");
// populate dests // populate dests
final int numDests = 800; final int numDests = 400;
final int numMessagesPerDest = 50; final int numMessagesPerDest = 50;
final int numConsumersPerDest = 5; final int numConsumersPerDest = 5;
populate(brokerAFactory, 0, numDests/2, numMessagesPerDest); populate(brokerAFactory, 0, numDests/2, numMessagesPerDest);
@ -148,7 +148,7 @@ public class DuplexAdvisoryRaceTest {
LOG.info("received: " + responseReceived.get()); LOG.info("received: " + responseReceived.get());
return responseReceived.get() >= numMessagesPerDest * numDests; return responseReceived.get() >= numMessagesPerDest * numDests;
} }
}, 5*60*1000)) { }, 10*60*1000)) {
org.apache.activemq.TestSupport.dumpAllThreads("DD"); org.apache.activemq.TestSupport.dumpAllThreads("DD");