svn commit: r1399168 - 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:51:40 2012
New Revision: 1399168

URL: http://svn.apache.org/viewvc?rev=1399168&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:r1398797

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=1399168&r1=1399167&r2=1399168&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:51:40 2012
@@ -24,10 +24,13 @@ import java.util.concurrent.ConcurrentHa
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
 
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
+import org.apache.camel.builder.NotifyBuilder;
 import org.apache.camel.builder.RouteBuilder;
+import org.junit.Ignore;
 import org.junit.Test;
 
 public class NettyConcurrentTest extends BaseNettyTest {
@@ -38,12 +41,18 @@ public class NettyConcurrentTest extends
     }
 
     @Test
-    public void testConcurrentProducers() throws Exception {
+    public void testSmallConcurrentProducers() throws Exception {
         doSendMessages(10, 5);
     }
 
+    @Test
+    @Ignore
+    public void testLargeConcurrentProducers() throws Exception {
+        doSendMessages(250000, 100);
+    }
+
     private void doSendMessages(int files, int poolSize) throws Exception {
-        getMockEndpoint("mock:result").expectedMessageCount(files);
+        NotifyBuilder notify = new 
NotifyBuilder(context).whenDone(files).create();
 
         ExecutorService executor = Executors.newFixedThreadPool(poolSize);
         Map<Integer, Future<String>> responses = new 
ConcurrentHashMap<Integer, Future<String>>();
@@ -52,7 +61,7 @@ public class NettyConcurrentTest extends
             Future<String> out = executor.submit(new Callable<String>() {
                 public String call() throws Exception {
                     String reply = 
template.requestBody("netty:tcp://localhost:{{port}}", index, String.class);
-                    log.info("Sent {} received {}", index, reply);
+                    log.debug("Sent {} received {}", index, reply);
                     assertEquals("Bye " + index, reply);
                     return reply;
                 }
@@ -60,7 +69,7 @@ public class NettyConcurrentTest extends
             responses.put(index, out);
         }
 
-        assertMockEndpointsSatisfied();
+        notify.matches(2, TimeUnit.MINUTES);
         assertEquals(files, responses.size());
 
         // get all responses
@@ -83,7 +92,7 @@ public class NettyConcurrentTest extends
                         String body = exchange.getIn().getBody(String.class);
                         exchange.getOut().setBody("Bye " + body);
                     }
-                }).to("mock:result");
+                }).to("log:progress?groupSize=1000");
             }
         };
     }