You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kie.apache.org by mw...@apache.org on 2026/06/22 14:46:12 UTC
(incubator-kie-kogito-apps) branch main updated: [incubator-kie-issues#2350] Skip interposed synchronization registration when the transaction is not active (#2346)
This is an automated email from the ASF dual-hosted git repository.
martinweiler pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
The following commit(s) were added to refs/heads/main by this push:
new b287d83a3 [incubator-kie-issues#2350] Skip interposed synchronization registration when the transaction is not active (#2346)
b287d83a3 is described below
commit b287d83a33ca0a326b034eac07f89b21eb2b017a
Author: Abhiram Gundala <16...@users.noreply.github.com>
AuthorDate: Mon Jun 22 10:46:07 2026 -0400
[incubator-kie-issues#2350] Skip interposed synchronization registration when the transaction is not active (#2346)
springboot guard
---
.../main/java/org/kie/kogito/app/jobs/quarkus/QuarkusJobsService.java | 3 +++
.../java/org/kie/kogito/app/jobs/springboot/SpringbootJobsService.java | 3 +++
2 files changed, 6 insertions(+)
diff --git a/kogito-apps-quarkus/jobs-quarkus/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusJobsService.java b/kogito-apps-quarkus/jobs-quarkus/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusJobsService.java
index f6431b1c2..77be00aaa 100644
--- a/kogito-apps-quarkus/jobs-quarkus/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusJobsService.java
+++ b/kogito-apps-quarkus/jobs-quarkus/kogito-addons-quarkus-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/quarkus/QuarkusJobsService.java
@@ -119,6 +119,9 @@ public class QuarkusJobsService implements JobsService {
@Override
public void synchronize(Runnable action) {
+ if (registry.getTransactionStatus() != Status.STATUS_ACTIVE) {
+ return;
+ }
registry.registerInterposedSynchronization(new Synchronization() {
@Override
diff --git a/kogito-apps-springboot/jobs-springboot/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/SpringbootJobsService.java b/kogito-apps-springboot/jobs-springboot/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/SpringbootJobsService.java
index 350e29930..47c42cbea 100644
--- a/kogito-apps-springboot/jobs-springboot/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/SpringbootJobsService.java
+++ b/kogito-apps-springboot/jobs-springboot/kogito-addons-springboot-embedded-jobs/src/main/java/org/kie/kogito/app/jobs/springboot/SpringbootJobsService.java
@@ -118,6 +118,9 @@ public class SpringbootJobsService implements JobsService {
@Override
public void synchronize(Runnable action) {
+ if (!TransactionSynchronizationManager.isSynchronizationActive()) {
+ return;
+ }
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override
public void afterCommit() {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org