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

make perf test num producers configurable via command line to allow easy comparison, make test use transacted sends 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@947638 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-05-24 13:28:51 +00:00
parent 09642bbcfa
commit c92fe9992b
3 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-core/pom.xml
View File

@ -54,6 +54,7 @@
'=META-INF.services.org.apache.xbean.spring.http.activemq.apache.org.schema';-noimport:=true '=META-INF.services.org.apache.xbean.spring.http.activemq.apache.org.schema';-noimport:=true
</activemq.osgi.export> </activemq.osgi.export>
<activemq.osgi.dynamic.import>*</activemq.osgi.dynamic.import> <activemq.osgi.dynamic.import>*</activemq.osgi.dynamic.import>
<surefire.argLine>-Xmx512M</surefire.argLine>
</properties> </properties>
<dependencies> <dependencies>
@ -408,7 +409,7 @@
<forkMode>pertest</forkMode> <forkMode>pertest</forkMode>
<childDelegation>false</childDelegation> <childDelegation>false</childDelegation>
<useFile>true</useFile> <useFile>true</useFile>
<argLine>-Xmx512M</argLine> <argLine>${surefire.argLine}</argLine>
<systemProperties> <systemProperties>
<property> <property>

4
activemq-core/src/test/java/org/apache/activemq/perf/KahaDBDurableTransactedTopicTest.java
View File

@ -23,11 +23,11 @@ import javax.jms.JMSException;
/** /**
* @version $Revision: 1.3 $ * @version $Revision: 1.3 $
*/ */
public class KahaDBDurableTransactedTopicTest extends SimpleDurableTopicTest { public class KahaDBDurableTransactedTopicTest extends KahaDBDurableTopicTest {
@Override @Override
protected PerfProducer createProducer(ConnectionFactory fac, Destination dest, int number, byte[] payload) throws JMSException { protected PerfProducer createProducer(ConnectionFactory fac, Destination dest, int number, byte[] payload) throws JMSException {
return new PerfProducer(fac, dest, payload); return new PerfProducer(fac, dest, payload, true);
} }

4
activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java
View File

@ -33,8 +33,8 @@ public class SimpleDurableTopicTest extends SimpleTopicTest {
protected void setUp() throws Exception { protected void setUp() throws Exception {
numberOfDestinations=1; numberOfDestinations=1;
numberOfConsumers = 2; numberOfConsumers = 2;
numberofProducers = 1; numberofProducers = Integer.parseInt(System.getProperty("SimpleDurableTopicTest.numberofProducers", "1"), 10);
sampleCount=1000; sampleCount= Integer.parseInt(System.getProperty("SimpleDurableTopicTest.sampleCount", "1000"), 10);
playloadSize = 1024; playloadSize = 1024;
super.setUp(); super.setUp();
} }