Author: davsclaus
Date: Wed Nov 4 08:01:34 2009
New Revision: 832674
URL: http://svn.apache.org/viewvc?rev=832674&view=rev
Log:
Fixed unit test.
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorRouteNumberOfProcessorTest.java
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorRouteNumberOfProcessorTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorRouteNumberOfProcessorTest.java?rev=832674&r1=832673&r2=832674&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorRouteNumberOfProcessorTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorRouteNumberOfProcessorTest.java
Wed Nov 4 08:01:34 2009
@@ -18,7 +18,6 @@
import org.apache.camel.ContextTestSupport;
import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
@@ -54,7 +53,7 @@
hasOut = newExchange.hasOut();
return newExchange;
}
- }).batchSize(2).batchTimeout(2000)
+ }).batchSize(2).batchTimeout(5000)
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
String s =
exchange.getIn().getBody(String.class);
@@ -99,7 +98,7 @@
hasOut = newExchange.hasOut();
return newExchange;
}
- }).batchSize(2).batchTimeout(2000)
+ }).batchSize(2).batchTimeout(5000)
.to("log:foo")
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
