From 1127709e778b37b3170860a00b73ee481d63adaf Mon Sep 17 00:00:00 2001 From: Francisco Javier Tirado Sarti Date: Wed, 22 Nov 2023 11:38:42 +0100 Subject: [PATCH] [JBPM-10088] Adding trace to check timer cmt value --- .../timer/GlobalJpaTimerJobInstance.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/jbpm-persistence/jbpm-persistence-jpa/src/main/java/org/jbpm/persistence/timer/GlobalJpaTimerJobInstance.java b/jbpm-persistence/jbpm-persistence-jpa/src/main/java/org/jbpm/persistence/timer/GlobalJpaTimerJobInstance.java index 16b7de1cfb..01d2ba8268 100644 --- a/jbpm-persistence/jbpm-persistence-jpa/src/main/java/org/jbpm/persistence/timer/GlobalJpaTimerJobInstance.java +++ b/jbpm-persistence/jbpm-persistence-jpa/src/main/java/org/jbpm/persistence/timer/GlobalJpaTimerJobInstance.java @@ -160,18 +160,18 @@ protected boolean hasEnvironmentEntry(Environment environment, String name, Obje protected TransactionManager startTxIfNeeded(Environment environment) { - try { - if (hasEnvironmentEntry(environment, "IS_TIMER_CMT", true)) { - return null; - } - if (environment.get(EnvironmentName.TRANSACTION_MANAGER) instanceof ContainerManagedTransactionManager) { - TransactionManager tm = TransactionManagerFactory.get().newTransactionManager(); - - if (tm.begin()) { - return tm; - } - } - + try { + boolean isTimerCMT = hasEnvironmentEntry(environment, "IS_TIMER_CMT", true); + logger.debug ("Timer CMT value is {}", isTimerCMT); + if (!isTimerCMT) { + if (environment.get(EnvironmentName.TRANSACTION_MANAGER) instanceof ContainerManagedTransactionManager) { + TransactionManager tm = TransactionManagerFactory.get().newTransactionManager(); + + if (tm.begin()) { + return tm; + } + } + } } catch (Exception e) { logger.debug("Unable to optionally start transaction due to {}", e.getMessage(), e); }