Avoid deprecated usingWhen method in Reactor 3.3
Closes gh-23562
This commit is contained in:
parent
393a81d4a9
commit
a48c13ae73
|
@ -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())
|
||||
|
|
Loading…
Reference in New Issue