Author: davsclaus
Date: Sun Jul 20 00:12:17 2008
New Revision: 678255
URL:
http://svn.apache.org/viewvc?rev=678255&view=revLog:
CAMEL-738: Added unit test
Added:
activemq/camel/trunk/components/camel-ftp/src/test/data/ftpbinarytest/logo2.png (with props)
activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpSetNamesWithMultiDirectoriesTest.java
- copied, changed from r678254, activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToBinaryFilesTest.java
Added: activemq/camel/trunk/components/camel-ftp/src/test/data/ftpbinarytest/logo2.png
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-ftp/src/test/data/ftpbinarytest/logo2.png?rev=678255&view=auto==============================================================================
Binary file - no diff available.
Propchange: activemq/camel/trunk/components/camel-ftp/src/test/data/ftpbinarytest/logo2.png
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Copied: activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpSetNamesWithMultiDirectoriesTest.java (from r678254, activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToBinaryFilesTest.java)
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpSetNamesWithMultiDirectoriesTest.java?p2=activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpSetNamesWithMultiDirectoriesTest.java&p1=activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToBinaryFilesTest.java&r1=678254&r2=678255&rev=678255&view=diff==============================================================================
--- activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpToBinaryFilesTest.java (original)
+++ activemq/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpSetNamesWithMultiDirectoriesTest.java Sun Jul 20 00:12:17 2008
@@ -27,14 +27,16 @@
import org.apache.camel.converter.IOConverter;
/**
- * Unit test to verify that we can pool a BINARY file from the FTP Server and store it on a local file path
+ * Unit test to verify that using option setNames and having multi remote directories the files
+ * are stored locally in the same directory layout.
*/
-public class FromFtpToBinaryFilesTest extends FtpServerTestSupport {
+public class FromFtpSetNamesWithMultiDirectoriesTest extends FtpServerTestSupport {
- private String port = "20015";
+ private String port = "20016";
+
// must user "consumer." prefix on the parameters to the file component
private String ftpUrl = "ftp://admin@localhost:" + port + "/incoming?password=admin&binary=true"
- + "&consumer.delay=2000&consumer.recursive=true&consumer.append=false";
+ + "&consumer.delay=2000&consumer.recursive=true&consumer.append=false&consumer.setNames=true";
public void testFtpRoute() throws Exception {
MockEndpoint resultEndpoint = getMockEndpoint("mock:result");
@@ -48,15 +50,15 @@
Thread.sleep(1000);
// assert the file
- File file = new File("target/ftptest/a/logo1.jpeg");
+ File file = new File("target/ftpsetnamestest/data1/logo1.jpeg");
assertTrue("The binary file should exists", file.exists());
assertTrue("Logo size wrong", file.length() > 10000);
// assert the file
- file = new File("target/ftptest/logo.jpeg");
+ file = new File("target/ftpsetnamestest/data2/logo2.png");
assertTrue(" The binary file should exists", file.exists());
- assertTrue("Logo size wrong", file.length() > 10000);
-
+ assertTrue("Logo size wrong", file.length() > 50000);
+
// let some time pass to let the consumer etc. properly do its business before closing
Thread.sleep(1000);
}
@@ -74,35 +76,34 @@
private void prepareFtpServer() throws Exception {
// prepares the FTP Server by creating a file on the server that we want to unit
// test that we can pool and store as a local file
- String ftpUrl = "ftp://admin@localhost:" + port + "/incoming?password=admin&binary=true"
- + "&consumer.delay=2000&consumer.recursive=false&consumer.append=false";
+ String ftpUrl = "ftp://admin@localhost:" + port + "/incoming/data1/?password=admin&binary=true";
Endpoint endpoint = context.getEndpoint(ftpUrl);
Exchange exchange = endpoint.createExchange();
- exchange.getIn().setBody(IOConverter.toFile("src/test/data/ftpbinarytest/logo.jpeg"));
- exchange.getIn().setHeader(FileComponent.HEADER_FILE_NAME, "logo.jpeg");
+ exchange.getIn().setBody(IOConverter.toFile("src/test/data/ftpbinarytest/logo1.jpeg"));
+ exchange.getIn().setHeader(FileComponent.HEADER_FILE_NAME, "logo1.jpeg");
Producer producer = endpoint.createProducer();
producer.start();
producer.process(exchange);
producer.stop();
- ftpUrl = "ftp://admin@localhost:" + port + "/incoming/a?password=admin&binary=true"
- + "&consumer.delay=2000&consumer.recursive=false&consumer.append=false";
+
+ ftpUrl = "ftp://admin@localhost:" + port + "/incoming/data2/?password=admin&binary=true";
endpoint = context.getEndpoint(ftpUrl);
exchange = endpoint.createExchange();
- exchange.getIn().setBody(IOConverter.toFile("src/test/data/ftpbinarytest/logo1.jpeg"));
- exchange.getIn().setHeader(FileComponent.HEADER_FILE_NAME, "logo1.jpeg");
+ exchange.getIn().setBody(IOConverter.toFile("src/test/data/ftpbinarytest/logo2.png"));
+ exchange.getIn().setHeader(FileComponent.HEADER_FILE_NAME, "logo2.png");
producer = endpoint.createProducer();
producer.start();
producer.process(exchange);
producer.stop();
}
-
+
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
public void configure() throws Exception {
- String fileUrl = "file:target/ftptest/?noop=true";
+ String fileUrl = "file:target/ftpsetnamestest/?noop=true";
from(ftpUrl).to(fileUrl, "mock:result");
}
};
}
-}
+}
\ No newline at end of file
