svn commit: r921934 - /camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java

[davsclaus]

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();