public class TransactionManagerImpl extends Object implements TransactionManager, UserTransaction, TransactionSynchronizationRegistry, XidImporter, MonitorableTransactionManager, RecoverableTransactionManager
Modifier and Type | Field and Description |
---|---|
protected static int |
DEFAULT_TIMEOUT |
protected static byte[] |
DEFAULT_TM_ID |
Constructor and Description |
---|
TransactionManagerImpl() |
TransactionManagerImpl(int defaultTransactionTimeoutSeconds) |
TransactionManagerImpl(int defaultTransactionTimeoutSeconds,
TransactionLog transactionLog) |
TransactionManagerImpl(int defaultTransactionTimeoutSeconds,
XidFactory xidFactory,
TransactionLog transactionLog) |
protected static final int DEFAULT_TIMEOUT
protected static final byte[] DEFAULT_TM_ID
public TransactionManagerImpl() throws XAException
XAException
public TransactionManagerImpl(int defaultTransactionTimeoutSeconds) throws XAException
XAException
public TransactionManagerImpl(int defaultTransactionTimeoutSeconds, TransactionLog transactionLog) throws XAException
XAException
public TransactionManagerImpl(int defaultTransactionTimeoutSeconds, XidFactory xidFactory, TransactionLog transactionLog) throws XAException
XAException
public Transaction getTransaction()
getTransaction
in interface TransactionManager
public void setTransactionTimeout(int seconds) throws SystemException
setTransactionTimeout
in interface TransactionManager
setTransactionTimeout
in interface UserTransaction
SystemException
public int getStatus() throws SystemException
getStatus
in interface TransactionManager
getStatus
in interface UserTransaction
SystemException
public void begin() throws NotSupportedException, SystemException
begin
in interface TransactionManager
begin
in interface UserTransaction
NotSupportedException
SystemException
public Transaction begin(long transactionTimeoutMilliseconds) throws NotSupportedException, SystemException
NotSupportedException
SystemException
public Transaction suspend() throws SystemException
suspend
in interface TransactionManager
SystemException
public void resume(Transaction tx) throws IllegalStateException, InvalidTransactionException, SystemException
resume
in interface TransactionManager
IllegalStateException
InvalidTransactionException
SystemException
public Object getResource(Object key)
getResource
in interface TransactionSynchronizationRegistry
public boolean getRollbackOnly()
getRollbackOnly
in interface TransactionSynchronizationRegistry
public Object getTransactionKey()
getTransactionKey
in interface TransactionSynchronizationRegistry
public int getTransactionStatus()
getTransactionStatus
in interface TransactionSynchronizationRegistry
public void putResource(Object key, Object value)
putResource
in interface TransactionSynchronizationRegistry
public void registerInterposedSynchronization(Synchronization synchronization)
registerInterposedSynchronization
in interface TransactionSynchronizationRegistry
synchronization
- interposed synchronizationpublic void setRollbackOnly() throws IllegalStateException
setRollbackOnly
in interface TransactionManager
setRollbackOnly
in interface TransactionSynchronizationRegistry
setRollbackOnly
in interface UserTransaction
IllegalStateException
public void commit() throws HeuristicMixedException, HeuristicRollbackException, IllegalStateException, RollbackException, SecurityException, SystemException
commit
in interface TransactionManager
commit
in interface UserTransaction
HeuristicMixedException
HeuristicRollbackException
IllegalStateException
RollbackException
SecurityException
SystemException
public void rollback() throws IllegalStateException, SecurityException, SystemException
rollback
in interface TransactionManager
rollback
in interface UserTransaction
IllegalStateException
SecurityException
SystemException
public Transaction importXid(Xid xid, long transactionTimeoutMilliseconds) throws XAException, SystemException
importXid
in interface XidImporter
XAException
SystemException
public void commit(Transaction tx, boolean onePhase) throws XAException
commit
in interface XidImporter
XAException
public void forget(Transaction tx) throws XAException
forget
in interface XidImporter
XAException
public int prepare(Transaction tx) throws XAException
prepare
in interface XidImporter
XAException
public void rollback(Transaction tx) throws XAException
rollback
in interface XidImporter
XAException
public void recoveryError(Exception e)
recoveryError
in interface RecoverableTransactionManager
public void registerNamedXAResourceFactory(NamedXAResourceFactory namedXAResourceFactory)
registerNamedXAResourceFactory
in interface RecoverableTransactionManager
public void unregisterNamedXAResourceFactory(String namedXAResourceFactoryName)
unregisterNamedXAResourceFactory
in interface RecoverableTransactionManager
public Map<Xid,TransactionImpl> getExternalXids()
getExternalXids
in interface XidImporter
public void addTransactionAssociationListener(TransactionManagerMonitor listener)
addTransactionAssociationListener
in interface MonitorableTransactionManager
public void removeTransactionAssociationListener(TransactionManagerMonitor listener)
removeTransactionAssociationListener
in interface MonitorableTransactionManager
protected void fireThreadAssociated(Transaction tx)
protected void fireThreadUnassociated(Transaction tx)
public long getActiveCount()
public long getTotalCommits()
public long getTotalRollbacks()
public void resetStatistics()
Copyright © 2017. All rights reserved.