svn commit: r907557 - /camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerMaxMessagesPerPollTest.java

[davsclaus]

Author: davsclaus
Date: Mon Feb  8 06:39:04 2010
New Revision: 907557

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

Modified:
    
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerMaxMessagesPerPollTest.java

Modified: 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerMaxMessagesPerPollTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerMaxMessagesPerPollTest.java?rev=907557&r1=907556&r2=907557&view=diff
==============================================================================
--- 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerMaxMessagesPerPollTest.java
 (original)
+++ 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerMaxMessagesPerPollTest.java
 Mon Feb  8 06:39:04 2010
@@ -28,7 +28,7 @@
 public class FtpConsumerMaxMessagesPerPollTest extends FtpServerTestSupport {
 
     private String getFtpUrl() {
-        return "ftp://ad...@localhost:"; + getPort() + 
"/poll/?password=admin&delay=3000&delete=true&sortBy=file:name&maxMessagesPerPoll=2";
+        return "ftp://ad...@localhost:"; + getPort() + 
"/poll/?password=admin&delay=6000&delete=true&sortBy=file:name&maxMessagesPerPoll=2";
     }
 
     @Override
@@ -40,9 +40,12 @@
 
     @Test
     public void testMaxMessagesPerPoll() throws Exception {
+        // start route
+        context.startRoute("foo");
+
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedBodiesReceived("Bye World", "Godday World");
-        mock.setResultWaitTime(2000);
+        mock.setResultWaitTime(4000);
         mock.expectedPropertyReceived(Exchange.BATCH_SIZE, 2);
 
         assertMockEndpointsSatisfied();
@@ -63,7 +66,7 @@
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from(getFtpUrl()).to("mock:result");
+                
from(getFtpUrl()).noAutoStartup().routeId("foo").to("mock:result");
             }
         };
     }