svn commit: r1399165 - /camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java

[davsclaus]

Author: davsclaus
Date: Wed Oct 17 09:45:57 2012
New Revision: 1399165

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

Modified:
    
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java

Modified: 
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java?rev=1399165&r1=1399164&r2=1399165&view=diff
==============================================================================
--- 
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java
 (original)
+++ 
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConcurrentTest.java
 Wed Oct 17 09:45:57 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