Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.service.impl
Class XATransactionCommand  view XATransactionCommand download XATransactionCommand.java

java.lang.Object
  extended byorg.activemq.service.impl.AbstractTransaction
      extended byorg.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()