Fixed test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5e1423f7 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5e1423f7 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5e1423f7 Branch: refs/heads/master Commit: 5e1423f749d6b030e153083e8667b43b11e43a7f Parents: f453c66 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Apr 22 07:32:41 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Apr 22 07:32:41 2016 +0200 ---------------------------------------------------------------------- .../file/remote/FtpConsumerIdempotentMemoryRefTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/5e1423f7/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerIdempotentMemoryRefTest.java ---------------------------------------------------------------------- diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerIdempotentMemoryRefTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerIdempotentMemoryRefTest.java index 7524f00..dec0179 100644 --- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerIdempotentMemoryRefTest.java +++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FtpConsumerIdempotentMemoryRefTest.java @@ -65,7 +65,7 @@ public class FtpConsumerIdempotentMemoryRefTest extends FtpServerTestSupport { assertTrue(repo.contains("e.txt")); resetMocks(); - notify = new NotifyBuilder(context).whenDone(4).create(); + notify = new NotifyBuilder(context).whenDone(2).create(); getMockEndpoint("mock:result").expectedMessageCount(2); @@ -86,7 +86,9 @@ public class FtpConsumerIdempotentMemoryRefTest extends FtpServerTestSupport { protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { public void configure() throws Exception { - from(getFtpUrl()).to("mock:result"); + from(getFtpUrl()) + .to("log:result") + .to("mock:result"); } }; }
