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

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
This commit is contained in:
Hiram R. Chirino 2008-03-11 15:20:31 +00:00
parent 512b0c7e67
commit 75d43c027f
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java
View File

@ -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 * 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 * 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 * 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); private static final transient Log LOG = LogFactory.getLog(NetworkLoadTest.class);
// How many times do we sample? // 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. // Slower machines might need to make this bigger.
private static final long SAMPLE_DURATION = Integer.parseInt(System.getProperty("SAMPLES_DURATION", "" + 1000 * 1)); private static final long SAMPLE_DURATION = Integer.parseInt(System.getProperty("SAMPLES_DURATION", "" + 1000 * 5));
protected static final int BROKER_COUNT = 10; protected static final int BROKER_COUNT = 4;
protected static final int MESSAGE_SIZE = 2000; protected static final int MESSAGE_SIZE = 2000;
class ForwardingClient { class ForwardingClient {