Repository: camel Updated Branches: refs/heads/camel-2.19.x 6b2b0414c -> 34b7e68bf
CAMEL-9608 following up to take care of sharedEntityManager Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/34b7e68b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/34b7e68b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/34b7e68b Branch: refs/heads/camel-2.19.x Commit: 34b7e68bf77802ac26972d462dec8c432a0a7150 Parents: 6b2b041 Author: Tomohisa Igarashi <[email protected]> Authored: Wed Aug 23 12:29:18 2017 -0400 Committer: Tomohisa Igarashi <[email protected]> Committed: Wed Aug 23 12:37:41 2017 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/jpa/JpaConsumer.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/34b7e68b/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 a426077..43e69b5 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 @@ -93,7 +93,11 @@ public class JpaConsumer extends ScheduledBatchPollingConsumer { // Recreate EntityManager in case it is disposed due to transaction rollback if (entityManager == null) { - entityManager = entityManagerFactory.createEntityManager(); + if (getEndpoint().isSharedEntityManager()) { + this.entityManager = SharedEntityManagerCreator.createSharedEntityManager(entityManagerFactory); + } else { + this.entityManager = entityManagerFactory.createEntityManager(); + } LOG.trace("Recreated EntityManager {} on {}", entityManager, this); }
