camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r802706 - /camel/sandbox/tuning-experiment/components/camel-jms/src/test/java/org/apache/camel/component/jms/tuning/PerformanceRouteCountTest.java
Date Mon, 10 Aug 2009 09:45:03 GMT
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();



Mime
View raw message