camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r832674 - /camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorRouteNumberOfProcessorTest.java
Date Wed, 04 Nov 2009 08:01:34 GMT
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 {



Mime
View raw message