Fixed test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b371be6c Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b371be6c Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b371be6c Branch: refs/heads/camel-2.16.x Commit: b371be6caae4e5e42a886a3bd6961bb3499683fb Parents: 1951fd5 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Nov 23 08:25:22 2015 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Nov 23 08:25:40 2015 +0100 ---------------------------------------------------------------------- .../camel/processor/jpa/FileConsumerJpaIdempotentTest.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/b371be6c/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/FileConsumerJpaIdempotentTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/FileConsumerJpaIdempotentTest.java b/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/FileConsumerJpaIdempotentTest.java index 1777d37..276d86b 100644 --- a/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/FileConsumerJpaIdempotentTest.java +++ b/components/camel-jpa/src/test/java/org/apache/camel/processor/jpa/FileConsumerJpaIdempotentTest.java @@ -40,8 +40,8 @@ public class FileConsumerJpaIdempotentTest extends AbstractJpaTest { @Before public void setUp() throws Exception { - super.setUp(); deleteDirectory("target/idempotent"); + super.setUp(); template.sendBodyAndHeader("file://target/idempotent/", "Hello World", Exchange.FILE_NAME, "report.txt"); } @@ -49,7 +49,8 @@ public class FileConsumerJpaIdempotentTest extends AbstractJpaTest { protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { public void configure() throws Exception { - from("file://target/idempotent/?idempotent=true&idempotentRepository=#jpaStore&move=done/${file:name}").to("mock:result"); + from("file://target/idempotent/?idempotent=true&idempotentRepository=#jpaStore&move=done/${file:name}").routeId("foo").autoStartup(false) + .to("mock:result"); } }; } @@ -78,6 +79,8 @@ public class FileConsumerJpaIdempotentTest extends AbstractJpaTest { mock.expectedBodiesReceived("Hello World"); mock.expectedMessageCount(1); + context.startRoute("foo"); + assertMockEndpointsSatisfied(); Thread.sleep(1000);
