camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r921934 - /camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
Date Thu, 11 Mar 2010 16:50:41 GMT
Author: davsclaus
Date: Thu Mar 11 16:50:40 2010
New Revision: 921934

URL: http://svn.apache.org/viewvc?rev=921934&view=rev
Log:
Fixed test on other boxes

Modified:
    camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java

Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java?rev=921934&r1=921933&r2=921934&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
(original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
Thu Mar 11 16:50:40 2010
@@ -40,15 +40,17 @@ public class FileConcurrentAggregateBatc
                     .threads(20)
                     .beanRef("business")
                     .aggregate(header("country"), new MyBusinessTotal())
-                        .completionTimeout(2000L)
+                        .completionTimeout(4000L)
                         .to("mock:result");
             }
         });
+        context.start();
 
         long start = System.currentTimeMillis();
 
         MockEndpoint result = getMockEndpoint("mock:result");
         result.expectedBodiesReceivedInAnyOrder("2000", "2500");
+        result.setResultWaitTime(20000);
 
         assertMockEndpointsSatisfied();
 
@@ -64,15 +66,17 @@ public class FileConcurrentAggregateBatc
                     .setHeader("id", simple("${file:onlyname.noext}"))
                     .beanRef("business")
                     .aggregate(header("country"), new MyBusinessTotal())
-                        .completionTimeout(2000L)
+                        .completionTimeout(4000L)
                         .to("mock:result");
             }
         });
+        context.start();
 
         long start = System.currentTimeMillis();
 
         MockEndpoint result = getMockEndpoint("mock:result");
         result.expectedBodiesReceivedInAnyOrder("2000", "2500");
+        result.setResultWaitTime(20000);
 
         assertMockEndpointsSatisfied();
 



Mime
View raw message