Repository: camel Updated Branches: refs/heads/camel-2.16.x 1951fd560 -> b371be6ca refs/heads/master 8d3973d43 -> 5ebb037a1
Fixed test Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5ebb037a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5ebb037a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5ebb037a Branch: refs/heads/master Commit: 5ebb037a1c18c53c660027bd960be3edba38ea25 Parents: 8d3973d 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:22 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/5ebb037a/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);
