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 21:11:04 UTC
svn commit: r712251 -
/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/PipelineConcurrentTest.java
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");