Updated Branches: refs/heads/master faeb31ba5 -> 64d49457b
Polished. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/64d49457 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/64d49457 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/64d49457 Branch: refs/heads/master Commit: 64d49457b33ea5fcacd3dbddcdff316f3757b818 Parents: faeb31b Author: Babak Vahdat <bvah...@apache.org> Authored: Sat Nov 9 16:07:50 2013 +0100 Committer: Babak Vahdat <bvah...@apache.org> Committed: Sat Nov 9 16:07:50 2013 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/jpa/JpaProducer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/64d49457/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java index cf78d26..202f1d9 100644 --- a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java +++ b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaProducer.java @@ -61,15 +61,15 @@ public class JpaProducer extends DefaultProducer { if (values.getClass().isArray()) { Object[] array = (Object[])values; for (int index = 0; index < array.length; index++) { - save(array[index], entityManager); + save(array[index]); } } else if (values instanceof Collection) { Collection<?> collection = (Collection<?>)values; for (Object entity : collection) { - save(entity, entityManager); + save(entity); } } else { - Object managedEntity = save(values, entityManager); + Object managedEntity = save(values); if (!getEndpoint().isUsePersist()) { exchange.getIn().setBody(managedEntity); } @@ -88,7 +88,7 @@ public class JpaProducer extends DefaultProducer { * save the given entity end return the managed entity * @return the managed entity */ - private Object save(final Object entity, EntityManager entityManager) { + private Object save(final Object entity) { // there may be concurrency so need to join tx before persist/merge entityManager.joinTransaction(); if (getEndpoint().isUsePersist()) {
