Package | Description |
---|---|
org.springframework.transaction.reactive |
Support classes for reactive transaction management.
|
Modifier and Type | Method and Description |
---|---|
static reactor.core.publisher.Mono<TransactionSynchronizationManager> |
TransactionSynchronizationManager.forCurrentTransaction()
Get the
TransactionSynchronizationManager that is associated with
the current transaction context. |
Modifier and Type | Method and Description |
---|---|
protected abstract reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.doBegin(TransactionSynchronizationManager synchronizationManager,
Object transaction,
TransactionDefinition definition)
Begin a new transaction with semantics according to the given transaction
definition.
|
protected reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.doCleanupAfterCompletion(TransactionSynchronizationManager synchronizationManager,
Object transaction)
Cleanup resources after transaction completion.
|
protected abstract reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.doCommit(TransactionSynchronizationManager synchronizationManager,
GenericReactiveTransaction status)
Perform an actual commit of the given transaction.
|
protected abstract Object |
AbstractReactiveTransactionManager.doGetTransaction(TransactionSynchronizationManager synchronizationManager)
Return a transaction object for the current transaction state.
|
protected reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.doResume(TransactionSynchronizationManager synchronizationManager,
Object transaction,
Object suspendedResources)
Resume the resources of the current transaction.
|
protected abstract reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.doRollback(TransactionSynchronizationManager synchronizationManager,
GenericReactiveTransaction status)
Perform an actual rollback of the given transaction.
|
protected reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.doSetRollbackOnly(TransactionSynchronizationManager synchronizationManager,
GenericReactiveTransaction status)
Set the given transaction rollback-only.
|
protected reactor.core.publisher.Mono<Object> |
AbstractReactiveTransactionManager.doSuspend(TransactionSynchronizationManager synchronizationManager,
Object transaction)
Suspend the resources of the current transaction.
|
protected reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.prepareForCommit(TransactionSynchronizationManager synchronizationManager,
GenericReactiveTransaction status)
Make preparations for commit, to be performed before the
beforeCommit synchronization callbacks occur. |
protected reactor.core.publisher.Mono<Void> |
AbstractReactiveTransactionManager.registerAfterCompletionWithExistingTransaction(TransactionSynchronizationManager synchronizationManager,
Object transaction,
List<TransactionSynchronization> synchronizations)
Register the given list of transaction synchronizations with the existing transaction.
|
Constructor and Description |
---|
ReactiveResourceSynchronization(O resourceObject,
K resourceKey,
TransactionSynchronizationManager synchronizationManager)
Create a new ReactiveResourceSynchronization for the given holder.
|