Class GenericReactiveTransaction
- java.lang.Object
- org.springframework.transaction.reactive.GenericReactiveTransaction
- All Implemented Interfaces:
ReactiveTransaction,TransactionExecution
public class GenericReactiveTransaction extends Object implements ReactiveTransaction
Default implementation of theReactiveTransactioninterface, used byAbstractReactiveTransactionManager. Based on the concept of an underlying "transaction object".Holds all status information that
AbstractReactiveTransactionManagerneeds internally, including a generic transaction object determined by the concrete transaction manager implementation.NOTE: This is not intended for use with other ReactiveTransactionManager implementations, in particular not for mock transaction managers in testing environments.
- Since:
- 5.2
- Author:
- Mark Paluch, Juergen Hoeller
- See Also:
AbstractReactiveTransactionManager,getTransaction()
Constructor Summary
Constructors Constructor Description GenericReactiveTransaction(Object transaction, boolean newTransaction, boolean newSynchronization, boolean readOnly, boolean debug, Object suspendedResources)Create a newDefaultReactiveTransactionStatusinstance.
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ObjectgetSuspendedResources()Return the holder for resources that have been suspended for this transaction, if any.ObjectgetTransaction()Return the underlying transaction object.booleanhasTransaction()Return whether there is an actual transaction active.booleanisCompleted()Return whether this transaction is completed, that is, whether it has already been committed or rolled back.booleanisDebug()Return whether the progress of this transaction is debugged.booleanisNewSynchronization()Return if a new transaction synchronization has been opened for this transaction.booleanisNewTransaction()Return whether the present transaction is new; otherwise participating in an existing transaction, or potentially not running in an actual transaction in the first place.booleanisReadOnly()Return if this transaction is defined as read-only transaction.booleanisRollbackOnly()Determine the rollback-only flag via checking this ReactiveTransactionStatus.voidsetCompleted()Mark this transaction as completed, that is, committed or rolled back.voidsetRollbackOnly()Set the transaction rollback-only.
Constructor Detail
GenericReactiveTransaction
public GenericReactiveTransaction(@Nullable Object transaction, boolean newTransaction, boolean newSynchronization, boolean readOnly, boolean debug, @Nullable Object suspendedResources)
Create a newDefaultReactiveTransactionStatusinstance.- Parameters:
transaction- underlying transaction object that can hold state for the internal transaction implementationnewTransaction- if the transaction is new, otherwise participating in an existing transactionnewSynchronization- if a new transaction synchronization has been opened for the given transactionreadOnly- whether the transaction is marked as read-onlydebug- should debug logging be enabled for the handling of this transaction? Caching it in here can prevent repeated calls to ask the logging system whether debug logging should be enabled.suspendedResources- a holder for resources that have been suspended for this transaction, if any
Method Detail
getTransaction
public Object getTransaction()
Return the underlying transaction object.- Throws:
IllegalStateException- if no transaction is active
hasTransaction
public boolean hasTransaction()
Return whether there is an actual transaction active.
isNewTransaction
public boolean isNewTransaction()
Description copied from interface:TransactionExecutionReturn whether the present transaction is new; otherwise participating in an existing transaction, or potentially not running in an actual transaction in the first place.- Specified by:
isNewTransactionin interfaceTransactionExecution
isNewSynchronization
public boolean isNewSynchronization()
Return if a new transaction synchronization has been opened for this transaction.
isReadOnly
public boolean isReadOnly()
Return if this transaction is defined as read-only transaction.
isDebug
public boolean isDebug()
Return whether the progress of this transaction is debugged. This is used byAbstractReactiveTransactionManageras an optimization, to prevent repeated calls tologger.isDebugEnabled(). Not really intended for client code.
getSuspendedResources
@Nullable public Object getSuspendedResources()
Return the holder for resources that have been suspended for this transaction, if any.
setRollbackOnly
public void setRollbackOnly()
Description copied from interface:TransactionExecutionSet the transaction rollback-only. This instructs the transaction manager that the only possible outcome of the transaction may be a rollback, as alternative to throwing an exception which would in turn trigger a rollback.- Specified by:
setRollbackOnlyin interfaceTransactionExecution
isRollbackOnly
public boolean isRollbackOnly()
Determine the rollback-only flag via checking this ReactiveTransactionStatus.Will only return "true" if the application called
setRollbackOnlyon this TransactionStatus object.- Specified by:
isRollbackOnlyin interfaceTransactionExecution
setCompleted
public void setCompleted()
Mark this transaction as completed, that is, committed or rolled back.
isCompleted
public boolean isCompleted()
Description copied from interface:TransactionExecutionReturn whether this transaction is completed, that is, whether it has already been committed or rolled back.- Specified by:
isCompletedin interfaceTransactionExecution