From fdbe1a7125a1c9ee70dd508c667eef5f65335078 Mon Sep 17 00:00:00 2001
From: Tobias Schaefer <tobias.schaefer@envite.de>
Date: Fri, 11 Nov 2022 09:04:22 +0100
Subject: [PATCH] Close #438: Fix regression on fetchAndLock long poll.

---
 .../camunda/bpm/feature/tx/MnTransactionContext.java          | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/micronaut-camunda-bpm-feature/src/main/java/info/novatec/micronaut/camunda/bpm/feature/tx/MnTransactionContext.java b/micronaut-camunda-bpm-feature/src/main/java/info/novatec/micronaut/camunda/bpm/feature/tx/MnTransactionContext.java
index 192a3996..5de638a4 100644
--- a/micronaut-camunda-bpm-feature/src/main/java/info/novatec/micronaut/camunda/bpm/feature/tx/MnTransactionContext.java
+++ b/micronaut-camunda-bpm-feature/src/main/java/info/novatec/micronaut/camunda/bpm/feature/tx/MnTransactionContext.java
@@ -45,7 +45,7 @@ public MnTransactionContext(CommandContext commandContext, SynchronousTransactio
         this.commandContext = commandContext;
         this.transactionManager = transactionManager;
 
-        TransactionSynchronizationManager.getSynchronousTransactionState(new TransactionSynchronizationAdapter() {
+        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
             @Override
             public void beforeCommit(boolean readOnly) {
                 lastTransactionState = COMMITTING;
@@ -123,7 +123,7 @@ public void afterCompletion(@NonNull Status status) {
             default:
                 throw new IllegalStateException("Unknown transaction state: " + transactionState);
         }
-        TransactionSynchronizationManager.getSynchronousTransactionState(transactionSynchronization);
+        TransactionSynchronizationManager.registerSynchronization(transactionSynchronization);
     }
 
     @Override