svn commit: r712251 - /activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java

[hadrian]

Author: hadrian
Date: Fri Nov  7 12:11:04 2008
New Revision: 712251

URL: http://svn.apache.org/viewvc?rev=712251&view=rev
Log:
CAMEL-1062.

Modified:
    
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java

Modified: 
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java?rev=712251&r1=712250&r2=712251&view=diff
==============================================================================
--- 
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java
 (original)
+++ 
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java
 Fri Nov  7 12:11:04 2008
@@ -51,7 +51,7 @@
                         } catch (InterruptedException e) {
                             // ignore
                         }
-                        template.sendBody("seda:in", "" + (start + i));
+                        template.sendBody("seda:in?size=10000", "" + (start + 
i));
                     }
                 }
             });
@@ -64,10 +64,10 @@
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                // to force any exceptions coming forward imeddiately
+                // to force any exceptions coming forward immediately
                 errorHandler(noErrorHandler());
 
-                from("seda:in")
+                from("seda:in?size=10000")
                     .thread(10)
                     .pipeline("direct:do", "mock:result");