org.codehaus.activemq.service.impl
Class XATransactionCommand

java.lang.Object
  extended byorg.codehaus.activemq.service.impl.AbstractTransaction
      extended byorg.codehaus.activemq.service.impl.XATransactionCommand
All Implemented Interfaces:
Externalizable, Serializable, Transaction

public class XATransactionCommand
extends AbstractTransaction

Version:
$Revision: 1.3 $
See Also:
Serialized Form

Field Summary
 
Fields inherited from class org.codehaus.activemq.service.impl.AbstractTransaction
FINISHED_STATE, IN_USE_STATE, PREPARED_STATE, START_STATE
 
Constructor Summary
XATransactionCommand()
          This constructor is only used when deserializing from disk
XATransactionCommand(Broker broker, ActiveMQXid xid, Map xaTxs, PreparedTransactionStore preparedTransactions)
           
 
Method Summary
 void commit(boolean onePhase)
           
static Transaction fromBytes(byte[] data)
           
 void initialise(Map xaTxs, PreparedTransactionStore preparedTransactions)
          Called after the transaction command has been recovered from disk
 int prepare()
           
 void readExternal(ObjectInput in)
           
 void rollback()
           
 byte[] toBytes()
           
 void writeExternal(ObjectOutput out)
           
 
Methods inherited from class org.codehaus.activemq.service.impl.AbstractTransaction
addPostCommitTask, addPostRollbackTask, addPrePrepareTask, getBroker, getState, postCommit, postRollback, prePrepare, readTask, readTaskList, setBroker, setState, toString, writeTask, writeTaskList
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

XATransactionCommand

public XATransactionCommand()
This constructor is only used when deserializing from disk


XATransactionCommand

public XATransactionCommand(Broker broker,
                            ActiveMQXid xid,
                            Map xaTxs,
                            PreparedTransactionStore preparedTransactions)
Method Detail

initialise

public void initialise(Map xaTxs,
                       PreparedTransactionStore preparedTransactions)
Called after the transaction command has been recovered from disk

Parameters:
xaTxs -
preparedTransactions -

commit

public void commit(boolean onePhase)
            throws XAException
Throws:
XAException

rollback

public void rollback()
              throws XAException
Throws:
XAException

prepare

public int prepare()
            throws XAException
Throws:
XAException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException
Specified by:
readExternal in interface Externalizable
Overrides:
readExternal in class AbstractTransaction
Throws:
IOException
ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException
Specified by:
writeExternal in interface Externalizable
Overrides:
writeExternal in class AbstractTransaction
Throws:
IOException

fromBytes

public static Transaction fromBytes(byte[] data)
                             throws IOException,
                                    ClassNotFoundException
Throws:
IOException
ClassNotFoundException

toBytes

public byte[] toBytes()
               throws IOException
Throws:
IOException


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.