[JBPM-10087] Trying to create new transaction to perform query (#2274)

kiegroup · Mar 16, 2023 · 454fe3d · 454fe3d
1 parent e384df9
commit 454fe3d
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/...bpm-services-ejb-timer/src/main/java/org/jbpm/services/ejb/timer/EjbSchedulerService.java b/...bpm-services-ejb-timer/src/main/java/org/jbpm/services/ejb/timer/EjbSchedulerService.java
@@ -171,14 +171,26 @@ private TimerMappingInfo getTimerMappingInfo(Function<EntityManager, List<TimerM
         String pu = ((InternalRuntimeManager) manager).getDeploymentDescriptor().getPersistenceUnit();
         EntityManagerFactory emf = EntityManagerFactoryManager.get().getOrCreate(pu);
         EntityManager em = emf.createEntityManager();
+        JtaTransactionManager tm = (JtaTransactionManager) TransactionManagerFactory.get().newTransactionManager();
+        boolean txOwner = false;
         try {
+            if (tm != null  && tm.getStatus() == TransactionManager.STATUS_ROLLEDBACK) {
+                txOwner = tm.begin();
+            }
             List<TimerMappingInfo> info = func.apply(em);
             if (!info.isEmpty()) {
                 return info.get(0);
             } else {
                 return null;
             }
+
+        } catch (Exception ex) {
+            logger.warn("Error getting mapping info ",ex);
+            return null;
         } finally {
+            if (tm != null) {
+                tm.commit(txOwner);
+            }
             em.close();
         }
     }