Author: davsclaus
Date: Sun Jul 20 00:12:17 2008
New Revision: 678255
URL: http://svn.apache.org/viewvc?rev=678255&view=rev
Log:
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://[EMAIL PROTECTED]:" + 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://[EMAIL PROTECTED]:" + port +
"/incoming?password=admin&binary=true"
- +
"&consumer.delay=2000&consumer.recursive=false&consumer.append=false";
+ String ftpUrl = "ftp://[EMAIL PROTECTED]:" + 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://[EMAIL PROTECTED]:" + port +
"/incoming/a?password=admin&binary=true"
- +
"&consumer.delay=2000&consumer.recursive=false&consumer.append=false";
+
+ ftpUrl = "ftp://[EMAIL PROTECTED]:" + 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
