Package | Description |
---|---|
org.springframework.r2dbc.connection |
Provides a utility class for easy ConnectionFactory access,
a ReactiveTransactionManager for a single ConnectionFactory,
and various simple ConnectionFactory implementations.
|
org.springframework.transaction.reactive |
Support classes for reactive transaction management.
|
Modifier and Type | Method and Description |
---|---|
protected reactor.core.publisher.Mono<Void> |
R2dbcTransactionManager.doBegin(TransactionSynchronizationManager synchronizationManager,
Object transaction,
TransactionDefinition definition) |
protected reactor.core.publisher.Mono<Void> |
R2dbcTransactionManager.doCleanupAfterCompletion(TransactionSynchronizationManager synchronizationManager,
Object transaction) |
protected reactor.core.publisher.Mono<Void> |
R2dbcTransactionManager.doCommit(TransactionSynchronizationManager TransactionSynchronizationManager,
GenericReactiveTransaction status) |
protected Object |
R2dbcTransactionManager.doGetTransaction(TransactionSynchronizationManager synchronizationManager) |
protected reactor.core.publisher.Mono<Void> |
R2dbcTransactionManager.doResume(TransactionSynchronizationManager synchronizationManager,
Object transaction,
Object suspendedResources) |
protected reactor.core.publisher.Mono<Void> |
R2dbcTransactionManager.doRollback(TransactionSynchronizationManager TransactionSynchronizationManager,
GenericReactiveTransaction status) |
protected reactor.core.publisher.Mono<Void> |
R2dbcTransactionManager.doSetRollbackOnly(TransactionSynchronizationManager synchronizationManager,
GenericReactiveTransaction status) |
protected reactor.core.publisher.Mono<Object> |
R2dbcTransactionManager.doSuspend(TransactionSynchronizationManager synchronizationManager,
Object transaction) |
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.
|