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

[davsclaus]

Author: davsclaus
Date: Thu Mar 11 15:29:53 2010
New Revision: 921898

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

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

Modified: 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java?rev=921898&r1=921897&r2=921898&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
 (original)
+++ 
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
 Thu Mar 11 15:29:53 2010
@@ -60,25 +60,32 @@ public class FileConcurrentTest extends 
         }
     }
 
+    @Override
+    public boolean isUseRouteBuilder() {
+        return false;
+    }
+
     public void testProcessFilesConcurrently() throws Exception {
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/concurrent?delay=60000&initialDelay=2500")
+                from("file://target/concurrent")
                     .setHeader("id", simple("${file:onlyname.noext}"))
                     .threads(20)
                     .beanRef("business")
                     .log("Country is ${in.header.country}")
                     .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();
 
@@ -90,19 +97,21 @@ public class FileConcurrentTest extends 
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/concurrent?delay=60000&initialDelay=2500")
+                from("file://target/concurrent")
                     .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();