You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2014/07/24 15:22:53 UTC
[3/3] git commit: 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.
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 <da...@apache.org>
Authored: Thu Jul 24 15:21:22 2014 +0200
Committer: Claus Ibsen <da...@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;
}
});