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