diff --git a/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperatorImpl.java b/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperatorImpl.java index 7e4c3fd5ab..d1a5779422 100644 --- a/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperatorImpl.java +++ b/spring-tx/src/main/java/org/springframework/transaction/reactive/TransactionalOperatorImpl.java @@ -80,7 +80,7 @@ final class TransactionalOperatorImpl implements TransactionalOperator { // Need re-wrapping of ReactiveTransaction until we get hold of the exception // through usingWhen. return status.flatMap(it -> Mono.usingWhen(Mono.just(it), ignore -> mono, - this.transactionManager::commit, s -> Mono.empty()) + this.transactionManager::commit, (res, err) -> Mono.empty(), s -> Mono.empty()) .onErrorResume(ex -> rollbackOnException(it, ex).then(Mono.error(ex)))); }) .subscriberContext(TransactionContextManager.getOrCreateContext())