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

[davsclaus]

Author: davsclaus
Date: Tue Nov 10 07:20:08 2009
New Revision: 834371

URL: http://svn.apache.org/viewvc?rev=834371&view=rev
Log:
CAMEL-2153: Added unit test.

Added:
    
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/ToFtpTempFileTargetFileExistTest.java
      - copied, changed from r834163, 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpPreMoveFilePrefixTest.java

Copied: 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/ToFtpTempFileTargetFileExistTest.java
 (from r834163, 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpPreMoveFilePrefixTest.java)
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/ToFtpTempFileTargetFileExistTest.java?p2=camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/ToFtpTempFileTargetFileExistTest.java&p1=camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpPreMoveFilePrefixTest.java&r1=834163&r2=834371&rev=834371&view=diff
==============================================================================
--- 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FromFtpPreMoveFilePrefixTest.java
 (original)
+++ 
camel/trunk/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/ToFtpTempFileTargetFileExistTest.java
 Tue Nov 10 07:20:08 2009
@@ -26,60 +26,54 @@
 import org.junit.Before;
 import org.junit.Test;
 
-/**
- * Unit test to test preMoveNamePrefix option.
- */
-public class FromFtpPreMoveFilePrefixTest extends FtpServerTestSupport {
+public class ToFtpTempFileTargetFileExistTest extends FtpServerTestSupport {
 
     private String getFtpUrl() {
-        return "ftp://ad...@localhost:"; + getPort() + 
"/movefile?password=admin&binary=false&consumer.delay=5000"
-                + "&preMove=done/${file:name}";
+        return "ftp://ad...@localhost:"; + getPort() + 
"/tempfile?password=admin&binary=false"
+                + 
"&fileName=./foo/bar/message.txt&tempFileName=${file:onlyname.noext}.tmp";
     }
 
     @Override
     @Before
     public void setUp() throws Exception {
-        deleteDirectory(FTP_ROOT_DIR + "movefile");
+        deleteDirectory(FTP_ROOT_DIR + "/tempfile");
         super.setUp();
         prepareFtpServer();
     }
 
     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
+        // prepares the FTP Server by creating a file on the server
         Endpoint endpoint = context.getEndpoint(getFtpUrl());
         Exchange exchange = endpoint.createExchange();
-        exchange.getIn().setBody("Hello World this file will be moved");
-        exchange.getIn().setHeader(Exchange.FILE_NAME, "hello.txt");
+        exchange.getIn().setBody("Hello World");
+        exchange.getIn().setHeader(Exchange.FILE_NAME, 
"./foo/bar/message.txt");
         Producer producer = endpoint.createProducer();
         producer.start();
         producer.process(exchange);
         producer.stop();
 
         // assert file is created
-        File file = new File(FTP_ROOT_DIR + "movefile/hello.txt");
+        File file = new File(FTP_ROOT_DIR + "/tempfile/foo/bar/message.txt");
         file = file.getAbsoluteFile();
         assertTrue("The file should exists", file.exists());
     }
 
     @Test
-    public void testPollFileAndShouldBeMoved() throws Exception {
+    public void testSendFileTargetFileExist() throws Exception {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedMessageCount(1);
-        mock.expectedBodiesReceived("Hello World this file will be moved");
+        mock.expectedBodiesReceived("Hello Again World");
+        mock.expectedFileExists(FTP_ROOT_DIR + 
"/tempfile/foo/bar/message.txt", "Hello Again World");
 
-        mock.assertIsSatisfied();
+        template.sendBody("direct:start", "Hello Again World");
 
-        // assert the file is moved
-        File file = new File(FTP_ROOT_DIR + "movefile/done/hello.txt");
-        file = file.getAbsoluteFile();
-        assertTrue("The file should have been moved", file.exists());
+        mock.assertIsSatisfied();
     }
 
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from(getFtpUrl()).to("mock:result");
+                from("direct:start").to(getFtpUrl()).to("mock:result");
             }
         };
     }