diff --git a/kie-spring/src/main/java/org/kie/spring/persistence/KieSpringJpaManager.java b/kie-spring/src/main/java/org/kie/spring/persistence/KieSpringJpaManager.java index c56f401136..5bd6c23aa3 100644 --- a/kie-spring/src/main/java/org/kie/spring/persistence/KieSpringJpaManager.java +++ b/kie-spring/src/main/java/org/kie/spring/persistence/KieSpringJpaManager.java @@ -124,7 +124,12 @@ public void endCommandScopedEntityManager() { if (this.env.get(EnvironmentName.CMD_SCOPED_ENTITY_MANAGER) != null) { getCommandScopedPersistenceContext().close(); } - + + // Code formerly in the clearPersistenceContext method. + EntityManager cmdScopedEntityManager = (EntityManager) this.env.get(EnvironmentName.CMD_SCOPED_ENTITY_MANAGER); + if (cmdScopedEntityManager != null) { + cmdScopedEntityManager.clear(); + } } } @@ -148,14 +153,4 @@ public ProcessPersistenceContext getProcessPersistenceContext() { return new JpaProcessPersistenceContext((EntityManager) this.env.get(EnvironmentName.CMD_SCOPED_ENTITY_MANAGER)); } - public void clearPersistenceContext() { - if (TransactionSynchronizationManager.hasResource("cmdEM")) { - EntityManager cmdScopedEntityManager = (EntityManager) this.env.get(EnvironmentName.CMD_SCOPED_ENTITY_MANAGER); - if (cmdScopedEntityManager != null) { - cmdScopedEntityManager.clear(); - } - - } - } - }