You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/08/10 11:45:03 UTC
svn commit: r802706 -
/camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java
Author: davsclaus
Date: Mon Aug 10 09:45:03 2009
New Revision: 802706
URL: http://svn.apache.org/viewvc?rev=802706&view=rev
Log:
tuning experiment
Modified:
camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java
Modified: camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java
URL: http://svn.apache.org/viewvc/camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java?rev=802706&r1=802705&r2=802706&view=diff
==============================================================================
--- camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java (original)
+++ camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java Mon Aug 10 09:45:03 2009
@@ -38,7 +38,7 @@
private AtomicInteger bronze = new AtomicInteger();
private AtomicInteger audit = new AtomicInteger();
- private int size = 1000;
+ private int size = 5000;
@Test
public void testPerformance() throws Exception {
@@ -66,10 +66,10 @@
// give time to finish
Thread.sleep(1000);
- System.out.println("gold " + gold.intValue());
- System.out.println("silver " + silver.intValue());
- System.out.println("bronze " + bronze.intValue());
- System.out.println("audit " + audit.intValue());
+// System.out.println("gold " + gold.intValue());
+// System.out.println("silver " + silver.intValue());
+// System.out.println("bronze " + bronze.intValue());
+// System.out.println("audit " + audit.intValue());
}
private boolean canRunOnThisPlatform() {
@@ -93,7 +93,7 @@
@Override
public void configure() throws Exception {
from("activemq:queue:inbox?concurrentConsumers=10")
- .wireTap("activemq:topic:audit")
+ .to("activemq:topic:audit")
.choice()
.when(header("type").isEqualTo("gold"))
.to("direct:gold")
@@ -111,7 +111,6 @@
});
from("direct:silver")
- .delay(5)
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
silver.incrementAndGet();
@@ -119,7 +118,6 @@
});
from("direct:bronze")
- .delay(10)
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
bronze.incrementAndGet();