Added an unit test of file endpoint from the user mailing list
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3697fbc9 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3697fbc9 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3697fbc9 Branch: refs/heads/master Commit: 3697fbc9741c085e895b9f0d00c21d8533fb9287 Parents: 41a6b93 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Tue Nov 25 10:53:32 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Tue Nov 25 16:18:14 2014 +0800 ---------------------------------------------------------------------- .../camel/component/file/FileConfigureTest.java | 24 ++++++++++++++++++++ 1 file changed, 24 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3697fbc9/camel-core/src/test/java/org/apache/camel/component/file/FileConfigureTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConfigureTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConfigureTest.java index e9d4bf5..3e1f8c0 100644 --- a/camel-core/src/test/java/org/apache/camel/component/file/FileConfigureTest.java +++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConfigureTest.java @@ -51,6 +51,30 @@ public class FileConfigureTest extends ContextTestSupport { assertFileEndpoint("file:///", File.separator, true); } + public void testUriWithParameters() throws Exception { + FileEndpoint endpoint = resolveMandatoryEndpoint("file:///C:/camel/temp?delay=10&useFixedDelay=true&initialDelay=10&consumer.bridgeErrorHandler=true" + + "&autoCreate=false&startingDirectoryMustExist=true&directoryMustExist=true&readLock=changed", FileEndpoint.class); + assertNotNull("Could not find file endpoint", endpoint); + assertEquals("Get a wrong option of StartingDirectoryMustExist", true, endpoint.isStartingDirectoryMustExist()); + + endpoint = resolveMandatoryEndpoint("file:///C:/camel/temp?delay=10&useFixedDelay=true&initialDelay=10&startingDirectoryMustExist=true" + + "&consumer.bridgeErrorHandler=true&autoCreate=false&directoryMustExist=true&readLock=changed", FileEndpoint.class); + + assertNotNull("Could not find file endpoint", endpoint); + assertEquals("Get a wrong option of StartingDirectoryMustExist", true, endpoint.isStartingDirectoryMustExist()); + + endpoint = resolveMandatoryEndpoint("file:///C:/camel/temp?delay=10&startingDirectoryMustExist=true&useFixedDelay=true&initialDelay=10" + + "&consumer.bridgeErrorHandler=true&autoCreate=false&directoryMustExist=true&readLock=changed", FileEndpoint.class); + + assertNotNull("Could not find file endpoint", endpoint); + assertEquals("Get a wrong option of StartingDirectoryMustExist", true, endpoint.isStartingDirectoryMustExist()); + + endpoint = resolveMandatoryEndpoint("file:///C:/camel/temp?delay=10&useFixedDelay=true&initialDelay=10", FileEndpoint.class); + + assertNotNull("Could not find file endpoint", endpoint); + assertEquals("Get a wrong option of StartingDirectoryMustExist", false, endpoint.isStartingDirectoryMustExist()); + } + public void testUriWithCharset() throws Exception { FileEndpoint endpoint = resolveMandatoryEndpoint("file://target/foo/bar?charset=UTF-8", FileEndpoint.class); assertNotNull("Could not find endpoint: file://target/foo/bar?charset=UTF-8", endpoint);
