public class TransactionManagerImpl extends java.lang.Object implements javax.transaction.TransactionManager, javax.transaction.UserTransaction, javax.transaction.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) |
| Modifier and Type | Method and Description |
|---|---|
void |
addTransactionAssociationListener(TransactionManagerMonitor listener) |
void |
begin() |
javax.transaction.Transaction |
begin(long transactionTimeoutMilliseconds) |
void |
commit() |
void |
commit(javax.transaction.Transaction tx,
boolean onePhase) |
protected void |
fireThreadAssociated(javax.transaction.Transaction tx) |
protected void |
fireThreadUnassociated(javax.transaction.Transaction tx) |
void |
forget(javax.transaction.Transaction tx) |
long |
getActiveCount()
Returns the number of active transactions.
|
java.util.Map<javax.transaction.xa.Xid,TransactionImpl> |
getExternalXids() |
java.lang.Object |
getResource(java.lang.Object key) |
boolean |
getRollbackOnly() |
int |
getStatus() |
long |
getTotalCommits()
Return the number of total commits
|
long |
getTotalRollbacks()
Returns the number of total rollbacks
|
javax.transaction.Transaction |
getTransaction() |
java.lang.Object |
getTransactionKey() |
int |
getTransactionStatus() |
javax.transaction.Transaction |
importXid(javax.transaction.xa.Xid xid,
long transactionTimeoutMilliseconds) |
int |
prepare(javax.transaction.Transaction tx) |
void |
putResource(java.lang.Object key,
java.lang.Object value) |
void |
recoveryError(java.lang.Exception e) |
void |
registerInterposedSynchronization(javax.transaction.Synchronization synchronization)
jta 1.1 method so the jpa implementations can be told to flush their caches.
|
void |
registerNamedXAResourceFactory(NamedXAResourceFactory namedXAResourceFactory) |
void |
removeTransactionAssociationListener(TransactionManagerMonitor listener) |
void |
resetStatistics()
Reset statistics
|
void |
resume(javax.transaction.Transaction tx) |
void |
rollback() |
void |
rollback(javax.transaction.Transaction tx) |
void |
setRollbackOnly() |
void |
setTransactionTimeout(int seconds) |
javax.transaction.Transaction |
suspend() |
void |
unregisterNamedXAResourceFactory(java.lang.String namedXAResourceFactoryName) |
protected static final int DEFAULT_TIMEOUT
protected static final byte[] DEFAULT_TM_ID
public TransactionManagerImpl()
throws javax.transaction.xa.XAException
javax.transaction.xa.XAExceptionpublic TransactionManagerImpl(int defaultTransactionTimeoutSeconds)
throws javax.transaction.xa.XAException
javax.transaction.xa.XAExceptionpublic TransactionManagerImpl(int defaultTransactionTimeoutSeconds,
TransactionLog transactionLog)
throws javax.transaction.xa.XAException
javax.transaction.xa.XAExceptionpublic TransactionManagerImpl(int defaultTransactionTimeoutSeconds,
XidFactory xidFactory,
TransactionLog transactionLog)
throws javax.transaction.xa.XAException
javax.transaction.xa.XAExceptionpublic javax.transaction.Transaction getTransaction()
getTransaction in interface javax.transaction.TransactionManagerpublic void setTransactionTimeout(int seconds)
throws javax.transaction.SystemException
setTransactionTimeout in interface javax.transaction.TransactionManagersetTransactionTimeout in interface javax.transaction.UserTransactionjavax.transaction.SystemExceptionpublic int getStatus()
throws javax.transaction.SystemException
getStatus in interface javax.transaction.TransactionManagergetStatus in interface javax.transaction.UserTransactionjavax.transaction.SystemExceptionpublic void begin()
throws javax.transaction.NotSupportedException,
javax.transaction.SystemException
begin in interface javax.transaction.TransactionManagerbegin in interface javax.transaction.UserTransactionjavax.transaction.NotSupportedExceptionjavax.transaction.SystemExceptionpublic javax.transaction.Transaction begin(long transactionTimeoutMilliseconds)
throws javax.transaction.NotSupportedException,
javax.transaction.SystemException
javax.transaction.NotSupportedExceptionjavax.transaction.SystemExceptionpublic javax.transaction.Transaction suspend()
throws javax.transaction.SystemException
suspend in interface javax.transaction.TransactionManagerjavax.transaction.SystemExceptionpublic void resume(javax.transaction.Transaction tx)
throws java.lang.IllegalStateException,
javax.transaction.InvalidTransactionException,
javax.transaction.SystemException
resume in interface javax.transaction.TransactionManagerjava.lang.IllegalStateExceptionjavax.transaction.InvalidTransactionExceptionjavax.transaction.SystemExceptionpublic java.lang.Object getResource(java.lang.Object key)
getResource in interface javax.transaction.TransactionSynchronizationRegistrypublic boolean getRollbackOnly()
getRollbackOnly in interface javax.transaction.TransactionSynchronizationRegistrypublic java.lang.Object getTransactionKey()
getTransactionKey in interface javax.transaction.TransactionSynchronizationRegistrypublic int getTransactionStatus()
getTransactionStatus in interface javax.transaction.TransactionSynchronizationRegistrypublic void putResource(java.lang.Object key,
java.lang.Object value)
putResource in interface javax.transaction.TransactionSynchronizationRegistrypublic void registerInterposedSynchronization(javax.transaction.Synchronization synchronization)
registerInterposedSynchronization in interface javax.transaction.TransactionSynchronizationRegistrysynchronization - interposed synchronizationpublic void setRollbackOnly()
throws java.lang.IllegalStateException
setRollbackOnly in interface javax.transaction.TransactionManagersetRollbackOnly in interface javax.transaction.TransactionSynchronizationRegistrysetRollbackOnly in interface javax.transaction.UserTransactionjava.lang.IllegalStateExceptionpublic void commit()
throws javax.transaction.HeuristicMixedException,
javax.transaction.HeuristicRollbackException,
java.lang.IllegalStateException,
javax.transaction.RollbackException,
java.lang.SecurityException,
javax.transaction.SystemException
commit in interface javax.transaction.TransactionManagercommit in interface javax.transaction.UserTransactionjavax.transaction.HeuristicMixedExceptionjavax.transaction.HeuristicRollbackExceptionjava.lang.IllegalStateExceptionjavax.transaction.RollbackExceptionjava.lang.SecurityExceptionjavax.transaction.SystemExceptionpublic void rollback()
throws java.lang.IllegalStateException,
java.lang.SecurityException,
javax.transaction.SystemException
rollback in interface javax.transaction.TransactionManagerrollback in interface javax.transaction.UserTransactionjava.lang.IllegalStateExceptionjava.lang.SecurityExceptionjavax.transaction.SystemExceptionpublic javax.transaction.Transaction importXid(javax.transaction.xa.Xid xid,
long transactionTimeoutMilliseconds)
throws javax.transaction.xa.XAException,
javax.transaction.SystemException
importXid in interface XidImporterjavax.transaction.xa.XAExceptionjavax.transaction.SystemExceptionpublic void commit(javax.transaction.Transaction tx,
boolean onePhase)
throws javax.transaction.xa.XAException
commit in interface XidImporterjavax.transaction.xa.XAExceptionpublic void forget(javax.transaction.Transaction tx)
throws javax.transaction.xa.XAException
forget in interface XidImporterjavax.transaction.xa.XAExceptionpublic int prepare(javax.transaction.Transaction tx)
throws javax.transaction.xa.XAException
prepare in interface XidImporterjavax.transaction.xa.XAExceptionpublic void rollback(javax.transaction.Transaction tx)
throws javax.transaction.xa.XAException
rollback in interface XidImporterjavax.transaction.xa.XAExceptionpublic void recoveryError(java.lang.Exception e)
recoveryError in interface RecoverableTransactionManagerpublic void registerNamedXAResourceFactory(NamedXAResourceFactory namedXAResourceFactory)
registerNamedXAResourceFactory in interface RecoverableTransactionManagerpublic void unregisterNamedXAResourceFactory(java.lang.String namedXAResourceFactoryName)
unregisterNamedXAResourceFactory in interface RecoverableTransactionManagerpublic java.util.Map<javax.transaction.xa.Xid,TransactionImpl> getExternalXids()
getExternalXids in interface XidImporterpublic void addTransactionAssociationListener(TransactionManagerMonitor listener)
addTransactionAssociationListener in interface MonitorableTransactionManagerpublic void removeTransactionAssociationListener(TransactionManagerMonitor listener)
removeTransactionAssociationListener in interface MonitorableTransactionManagerprotected void fireThreadAssociated(javax.transaction.Transaction tx)
protected void fireThreadUnassociated(javax.transaction.Transaction tx)
public long getActiveCount()
public long getTotalCommits()
public long getTotalRollbacks()
public void resetStatistics()
Copyright © 2003-2016 The Apache Software Foundation. All Rights Reserved.