public abstract class AbstractSpringTransactionManager extends org.springframework.transaction.support.AbstractPlatformTransactionManager implements org.springframework.transaction.support.ResourceTransactionManager, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractSpringTransactionManager.IgniteTransactionObject
An object representing a managed Ignite transaction.
|
Constructor and Description |
---|
AbstractSpringTransactionManager() |
Modifier and Type | Method and Description |
---|---|
protected abstract org.apache.ignite.internal.transactions.proxy.TransactionProxyFactory |
createTransactionFactory()
Creates instance of
TransactionProxyFactory that will be used to start new Ignite transactions. |
protected abstract TransactionConcurrency |
defaultTransactionConcurrency() |
protected abstract TransactionIsolation |
defaultTransactionIsolation() |
protected abstract long |
defaultTransactionTimeout() |
protected void |
doBegin(Object transaction,
org.springframework.transaction.TransactionDefinition definition) |
protected void |
doCleanupAfterCompletion(Object transaction) |
protected void |
doCommit(org.springframework.transaction.support.DefaultTransactionStatus status) |
protected Object |
doGetTransaction() |
protected void |
doRollback(org.springframework.transaction.support.DefaultTransactionStatus status) |
protected void |
doSetRollbackOnly(org.springframework.transaction.support.DefaultTransactionStatus status) |
Object |
getResourceFactory() |
TransactionConcurrency |
getTransactionConcurrency()
Gets transaction concurrency level.
|
protected boolean |
isExistingTransaction(Object transaction) |
protected abstract IgniteLogger |
log() |
void |
onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent evt) |
void |
setTransactionConcurrency(TransactionConcurrency txConcurrency)
Sets transaction concurrency level.
|
commit, determineTimeout, doResume, doSuspend, getDefaultTimeout, getTransaction, getTransactionSynchronization, invokeAfterCompletion, isFailEarlyOnGlobalRollbackOnly, isGlobalRollbackOnParticipationFailure, isNestedTransactionAllowed, isRollbackOnCommitFailure, isValidateExistingTransaction, newTransactionStatus, prepareForCommit, prepareSynchronization, prepareTransactionStatus, registerAfterCompletionWithExistingTransaction, resume, rollback, setDefaultTimeout, setFailEarlyOnGlobalRollbackOnly, setGlobalRollbackOnParticipationFailure, setNestedTransactionAllowed, setRollbackOnCommitFailure, setTransactionSynchronization, setTransactionSynchronizationName, setValidateExistingTransaction, shouldCommitOnGlobalRollbackOnly, suspend, triggerBeforeCommit, triggerBeforeCompletion, useSavepointForNestedTransaction
public TransactionConcurrency getTransactionConcurrency()
public void setTransactionConcurrency(TransactionConcurrency txConcurrency)
txConcurrency
- transaction concurrency level.public void onApplicationEvent(org.springframework.context.event.ContextRefreshedEvent evt)
onApplicationEvent
in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>
protected Object doGetTransaction() throws org.springframework.transaction.TransactionException
doGetTransaction
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
org.springframework.transaction.TransactionException
protected void doBegin(Object transaction, org.springframework.transaction.TransactionDefinition definition) throws org.springframework.transaction.TransactionException
doBegin
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
org.springframework.transaction.TransactionException
protected void doCommit(org.springframework.transaction.support.DefaultTransactionStatus status) throws org.springframework.transaction.TransactionException
doCommit
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
org.springframework.transaction.TransactionException
protected void doRollback(org.springframework.transaction.support.DefaultTransactionStatus status) throws org.springframework.transaction.TransactionException
doRollback
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
org.springframework.transaction.TransactionException
protected void doSetRollbackOnly(org.springframework.transaction.support.DefaultTransactionStatus status) throws org.springframework.transaction.TransactionException
doSetRollbackOnly
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
org.springframework.transaction.TransactionException
protected void doCleanupAfterCompletion(Object transaction)
doCleanupAfterCompletion
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
protected boolean isExistingTransaction(Object transaction) throws org.springframework.transaction.TransactionException
isExistingTransaction
in class org.springframework.transaction.support.AbstractPlatformTransactionManager
org.springframework.transaction.TransactionException
public Object getResourceFactory()
getResourceFactory
in interface org.springframework.transaction.support.ResourceTransactionManager
protected abstract TransactionIsolation defaultTransactionIsolation()
protected abstract long defaultTransactionTimeout()
protected abstract TransactionConcurrency defaultTransactionConcurrency()
protected abstract org.apache.ignite.internal.transactions.proxy.TransactionProxyFactory createTransactionFactory()
TransactionProxyFactory
that will be used to start new Ignite transactions.protected abstract IgniteLogger log()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021