You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2008/08/07 03:52:47 UTC
svn commit: r683470 -
/activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToMockTest.java
Author: ningjiang
Date: Wed Aug 6 18:52:47 2008
New Revision: 683470
URL: http://svn.apache.org/viewvc?rev=683470&view=rev
Log:
Fixed the test error of FromFtpToMockTest
Modified:
activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToMockTest.java
Modified: activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToMockTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToMockTest.java?rev=683470&r1=683469&r2=683470&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToMockTest.java (original)
+++ activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToMockTest.java Wed Aug 6 18:52:47 2008
@@ -25,8 +25,8 @@
public class FromFtpToMockTest extends FtpServerTestSupport {
protected MockEndpoint resultEndpoint;
protected String expectedBody = "Hello there!";
- protected String port = "20010";
- protected String ftpUrl = "ftp://admin@localhost:" + port + "/tmp/camel?password=admin";
+ protected String port = "2001";
+ protected String ftpUrl = "ftp://admin@localhost:" + port + "/tmp/camel?password=admin&consumer.recursive=true";
public void testFtpRoute() throws Exception {
MockEndpoint resultEndpoint = getMockEndpoint("mock:result");
@@ -37,10 +37,14 @@
//resultEndpoint.message(0).header("cheese").isEqualTo(123);
template.sendBodyAndHeader(ftpUrl, expectedBody, "cheese", 123);
+ // let some time pass to let the consumer etc. properly do its business before closing
+ Thread.sleep(1000);
+
resultEndpoint.assertIsSatisfied();
- // let some time pass to let the consumer etc. properly do its business before closing
Thread.sleep(1000);
+
+
}
protected RouteBuilder createRouteBuilder() throws Exception {