|
|||||||||
| Home >> All >> org >> activemq >> service >> [ impl overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
org.activemq.service.impl
Class XATransactionCommand

java.lang.Objectorg.activemq.service.impl.AbstractTransaction
org.activemq.service.impl.XATransactionCommand
- All Implemented Interfaces:
- org.activemq.service.Transaction
- public class XATransactionCommand
- extends AbstractTransaction
- Version:
- $Revision: 1.1.1.1 $
| Field Summary | |
private static org.apache.commons.logging.Log |
log
|
private org.activemq.store.TransactionStore |
transactionStore
|
private java.util.Map |
xaTxs
|
private org.activemq.message.ActiveMQXid |
xid
|
| Fields inherited from class org.activemq.service.impl.AbstractTransaction |
FINISHED_STATE, IN_USE_STATE, PREPARED_STATE, START_STATE |
| Constructor Summary | |
XATransactionCommand(org.activemq.message.ActiveMQXid xid,
java.util.Map xaTxs,
org.activemq.store.TransactionStore transactionStore)
|
|
| Method Summary | |
private void |
checkForPreparedState(boolean onePhase)
|
void |
commit(boolean onePhase)
|
private void |
doPostCommit()
|
private void |
doPostRollback()
|
private void |
doPrePrepare()
|
java.lang.Object |
getTransactionId()
|
private void |
illegalStateTransition(java.lang.String callName)
|
void |
initialise(java.util.Map xaTxs,
org.activemq.store.TransactionStore preparedTransactions)
Called after the transaction command has been recovered from disk |
boolean |
isXaTransacted()
|
int |
prepare()
|
void |
rollback()
|
private void |
setStateFinished()
|
| Methods inherited from class org.activemq.service.impl.AbstractTransaction |
addPostCommitTask, addPostRollbackTask, addPrePrepareTask, getState, postCommit, postRollback, prePrepare, setState, toString |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Field Detail |
log
private static final org.apache.commons.logging.Log log
xid
private org.activemq.message.ActiveMQXid xid
xaTxs
private transient java.util.Map xaTxs
transactionStore
private transient org.activemq.store.TransactionStore transactionStore
| Constructor Detail |
XATransactionCommand
public XATransactionCommand(org.activemq.message.ActiveMQXid xid, java.util.Map xaTxs, org.activemq.store.TransactionStore transactionStore)
| Method Detail |
initialise
public void initialise(java.util.Map xaTxs, org.activemq.store.TransactionStore preparedTransactions)
- Called after the transaction command has been recovered from disk
commit
public void commit(boolean onePhase)
throws javax.transaction.xa.XAException
illegalStateTransition
private void illegalStateTransition(java.lang.String callName) throws javax.transaction.xa.XAException
checkForPreparedState
private void checkForPreparedState(boolean onePhase)
throws javax.transaction.xa.XAException
doPrePrepare
private void doPrePrepare()
throws javax.transaction.xa.XAException
doPostCommit
private void doPostCommit()
throws javax.transaction.xa.XAException
rollback
public void rollback()
throws javax.transaction.xa.XAException
doPostRollback
private void doPostRollback()
throws javax.transaction.xa.XAException
prepare
public int prepare()
throws javax.transaction.xa.XAException
setStateFinished
private void setStateFinished()
isXaTransacted
public boolean isXaTransacted()
getTransactionId
public java.lang.Object getTransactionId()
|
|||||||||
| Home >> All >> org >> activemq >> service >> [ impl overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
JAVADOC