Updated Branches: refs/heads/camel-2.12.x b9976009f -> cd351f0d7
Polished. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cd351f0d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cd351f0d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cd351f0d Branch: refs/heads/camel-2.12.x Commit: cd351f0d74549e8705699a8755eea9ef56b31b11 Parents: b997600 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:09:09 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/cd351f0d/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()) {
