diff --git a/jbpm-services/jbpm-services-ejb/jbpm-services-ejb-timer/src/main/java/org/jbpm/services/ejb/timer/EjbSchedulerService.java b/jbpm-services/jbpm-services-ejb/jbpm-services-ejb-timer/src/main/java/org/jbpm/services/ejb/timer/EjbSchedulerService.java
index 1bad1ae27b..a6bc947c2b 100644
--- a/jbpm-services/jbpm-services-ejb/jbpm-services-ejb-timer/src/main/java/org/jbpm/services/ejb/timer/EjbSchedulerService.java
+++ b/jbpm-services/jbpm-services-ejb/jbpm-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();
         }
     }