Browse Source

Add missing return in AbstractReactiveTransactionManager.processCommit()

pull/22898/head
Sam Brannen 7 years ago
parent
commit
3dc38a08c8
  1. 2
      spring-tx/src/main/java/org/springframework/transaction/reactive/AbstractReactiveTransactionManager.java

2
spring-tx/src/main/java/org/springframework/transaction/reactive/AbstractReactiveTransactionManager.java

@ -443,7 +443,7 @@ public abstract class AbstractReactiveTransactionManager implements ReactiveTran @@ -443,7 +443,7 @@ public abstract class AbstractReactiveTransactionManager implements ReactiveTran
return triggerAfterCompletion(synchronizationManager, status, TransactionSynchronization.STATUS_ROLLED_BACK).then(propagateException);
}
if (ErrorPredicates.TRANSACTION_EXCEPTION.test(ex)) {
triggerAfterCompletion(synchronizationManager, status, TransactionSynchronization.STATUS_UNKNOWN).then(propagateException);
return triggerAfterCompletion(synchronizationManager, status, TransactionSynchronization.STATUS_UNKNOWN).then(propagateException);
}
if (ErrorPredicates.RUNTIME_OR_ERROR.test(ex)) {
Mono<Void> mono;

Loading…
Cancel
Save