svn commit: r1399169 - in /camel/branches/camel-2.10.x: ./ components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java

[davsclaus]

Author: davsclaus
Date: Wed Oct 17 09:54:40 2012
New Revision: 1399169

URL: http://svn.apache.org/viewvc?rev=1399169&view=rev
Log:
Polished test

Modified:
    camel/branches/camel-2.10.x/   (props changed)
    
camel/branches/camel-2.10.x/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java

Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
  Merged /camel/trunk:r1399165

Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.

Modified: 
camel/branches/camel-2.10.x/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java
URL: 
http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java?rev=1399169&r1=1399168&r2=1399169&view=diff
==============================================================================
--- 
camel/branches/camel-2.10.x/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java
 (original)
+++ 
camel/branches/camel-2.10.x/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java
 Wed Oct 17 09:54:40 2012
@@ -30,6 +30,7 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.NotifyBuilder;
 import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.util.StopWatch;
 import org.junit.Ignore;
 import org.junit.Test;
 
@@ -52,6 +53,7 @@ public class NettyConcurrentTest extends
     }
 
     private void doSendMessages(int files, int poolSize) throws Exception {
+        StopWatch watch = new StopWatch();
         NotifyBuilder notify = new 
NotifyBuilder(context).whenDone(files).create();
 
         ExecutorService executor = Executors.newFixedThreadPool(poolSize);
@@ -70,6 +72,7 @@ public class NettyConcurrentTest extends
         }
 
         notify.matches(2, TimeUnit.MINUTES);
+        log.info("Took " + watch.taken() + " millis to process " + files + " 
messages using " + poolSize + " client threads.");
         assertEquals(files, responses.size());
 
         // get all responses