CAMEL-8765: JpaConsumer - May poll too soon before JPA stuff is initialized.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e137f17e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e137f17e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e137f17e Branch: refs/heads/camel-2.14.x Commit: e137f17ea545285e053921eafdfc78e82db1d3e3 Parents: c1bdc24 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun May 10 20:46:13 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun May 10 20:46:41 2015 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/jpa/JpaConsumer.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e137f17e/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java index 95c9d26..0a6ff8e 100644 --- a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java +++ b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaConsumer.java @@ -479,9 +479,11 @@ public class JpaConsumer extends ScheduledBatchPollingConsumer { @Override protected void doStart() throws Exception { - super.doStart(); + // need to setup entity manager first this.entityManager = entityManagerFactory.createEntityManager(); LOG.trace("Created EntityManager {} on {}", entityManager, this); + + super.doStart(); } @Override @@ -491,8 +493,9 @@ public class JpaConsumer extends ScheduledBatchPollingConsumer { @Override protected void doShutdown() throws Exception { - super.doShutdown(); this.entityManager.close(); LOG.trace("Closed EntityManager {} on {}", entityManager, this); + + super.doShutdown(); } }
