From 75d43c027f053d2dbfdf8878e0d24212c198e39c Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Tue, 11 Mar 2008 15:20:31 +0000 Subject: [PATCH] This test is very taxing.. if you didn't have a good machine it could produce false negatives.. lowering requirements a bit to reduce false negatives. git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635971 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/network/NetworkLoadTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java b/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java index 41324049c8..d84b860e63 100644 --- a/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java @@ -53,7 +53,7 @@ import org.apache.commons.logging.LogFactory; /** * This test case is used to load test store and forwarding between brokers. It sets up - * 10 brokers to which have a chain of queues which this test consumes and produces to. + * n brokers to which have a chain of queues which this test consumes and produces to. * * If the network bridges gets stuck at any point subsequent queues will not get messages. This test * samples the production and consumption stats every second and if the flow of messages @@ -66,10 +66,10 @@ public class NetworkLoadTest extends TestCase { private static final transient Log LOG = LogFactory.getLog(NetworkLoadTest.class); // How many times do we sample? - private static final long SAMPLES = Integer.parseInt(System.getProperty("SAMPLES", ""+60*1)); // 1 min since each sample is 1 sec long. + private static final long SAMPLES = Integer.parseInt(System.getProperty("SAMPLES", ""+60*1/5)); // Slower machines might need to make this bigger. - private static final long SAMPLE_DURATION = Integer.parseInt(System.getProperty("SAMPLES_DURATION", "" + 1000 * 1)); - protected static final int BROKER_COUNT = 10; + private static final long SAMPLE_DURATION = Integer.parseInt(System.getProperty("SAMPLES_DURATION", "" + 1000 * 5)); + protected static final int BROKER_COUNT = 4; protected static final int MESSAGE_SIZE = 2000; class ForwardingClient {