CAMEL-7598: JPA consumer should clear entity manager after flush to avoid any jpa provider to keep previous polled entities in any kind of cache that just eats up memory. Thanks to Daniel Seidewitz for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f39312fd Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f39312fd Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f39312fd Branch: refs/heads/camel-2.13.x Commit: f39312fd0274e42f2c9017f1fdbed2080d277edd Parents: 3b17bd3 Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Jul 24 15:21:22 2014 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Jul 24 15:22:35 2014 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/camel/component/jpa/JpaConsumer.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/f39312fd/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 8682e4b..483c311 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 @@ -135,6 +135,8 @@ public class JpaConsumer extends ScheduledBatchPollingConsumer { // commit LOG.debug("Flushing EntityManager"); entityManager.flush(); + // must clear after flush + entityManager.clear(); return messagePolled; } });
