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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
