You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2008/11/07 22:26:30 UTC

svn commit: r712269 - /activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java

Author: hadrian
Date: Fri Nov  7 13:26:30 2008
New Revision: 712269

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

Modified:
    activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java

Modified: activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java?rev=712269&r1=712268&r2=712269&view=diff
==============================================================================
--- activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java (original)
+++ activemq/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java Fri Nov  7 13:26:30 2008
@@ -51,7 +51,7 @@
                         } catch (InterruptedException e) {
                             // ignore
                         }
-                        template.sendBody("seda:in", "" + (start + i));
+                        template.sendBody("seda:in?size=10000", "" + (start + i));
                     }
                 }
             });
@@ -67,7 +67,7 @@
                 // to force any exceptions coming forward imeddiately
                 errorHandler(noErrorHandler());
 
-                from("seda:in")
+                from("seda:in?size=10000")
                     .thread(10)
                     .pipeline("direct:do", "mock:result");