org.hornetq.core.transaction.impl

Class TransactionImpl

java.lang.Object

org.hornetq.core.transaction.impl.TransactionImpl

All Implemented Interfaces:

Transaction

Direct Known Subclasses:

BindingsTransactionImpl

public class TransactionImpl
extends Object
implements Transaction

A TransactionImpl

Author:

Tim Fox,

Nested Class Summary

Nested classes/interfaces inherited from interface org.hornetq.core.transaction.Transaction

Transaction.State

Field Summary

Fields

Modifier and Type	Field and Description
protected StorageManager	storageManager

Constructor Summary

Constructors

Constructor and Description
TransactionImpl(long id, Xid xid, StorageManager storageManager)
TransactionImpl(StorageManager storageManager)
TransactionImpl(StorageManager storageManager, int timeoutSeconds)
TransactionImpl(Xid xid, StorageManager storageManager, int timeoutSeconds)

Method Summary

Methods

Modifier and Type	Method and Description
void	addOperation(TransactionOperation operation)
protected void	asyncAppendCommit()
void	commit()
void	commit(boolean onePhase)
protected void	doCommit()
List<TransactionOperation>	getAllOperations()
long	getCreateTime()
long	getID()
Object	getProperty(int index)
Transaction.State	getState()
Xid	getXid()
boolean	hasTimedOut(long currentTime, int defaultTimeout)
boolean	isContainsPersistent()
void	markAsRollbackOnly(HornetQException exception1)
void	prepare()
void	putProperty(int index, Object property)
void	resume()
void	rollback()
void	setContainsPersistent()
void	setState(Transaction.State state)
void	setTimeout(int timeout)
void	setWaitBeforeCommit(boolean waitBeforeCommit)
void	suspend()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

storageManager

protected final StorageManager storageManager

Constructor Detail

TransactionImpl

public TransactionImpl(StorageManager storageManager,
               int timeoutSeconds)

TransactionImpl

public TransactionImpl(StorageManager storageManager)

TransactionImpl

public TransactionImpl(Xid xid,
               StorageManager storageManager,
               int timeoutSeconds)

TransactionImpl

public TransactionImpl(long id,
               Xid xid,
               StorageManager storageManager)

Method Detail

setContainsPersistent

public void setContainsPersistent()

Specified by:

setContainsPersistent in interface Transaction

isContainsPersistent

public boolean isContainsPersistent()

Specified by:

isContainsPersistent in interface Transaction

setTimeout

public void setTimeout(int timeout)

Specified by:

setTimeout in interface Transaction

getID

public long getID()

Specified by:

getID in interface Transaction

getCreateTime

public long getCreateTime()

Specified by:

getCreateTime in interface Transaction

hasTimedOut

public boolean hasTimedOut(long currentTime,
                  int defaultTimeout)

Specified by:

hasTimedOut in interface Transaction

prepare

public void prepare()
             throws Exception

Specified by:

prepare in interface Transaction

Throws:

Exception

commit

public void commit()
            throws Exception

Specified by:

commit in interface Transaction

Throws:

Exception

commit

public void commit(boolean onePhase)
            throws Exception

Specified by:

commit in interface Transaction

Throws:

Exception

doCommit

protected void doCommit()
                 throws Exception

Throws:

Exception

asyncAppendCommit

protected void asyncAppendCommit()

rollback

public void rollback()
              throws Exception

Specified by:

rollback in interface Transaction

Throws:

Exception

suspend

public void suspend()

Specified by:

suspend in interface Transaction

resume

public void resume()

Specified by:

resume in interface Transaction

getState

public Transaction.State getState()

Specified by:

getState in interface Transaction

setState

public void setState(Transaction.State state)

Specified by:

setState in interface Transaction

setWaitBeforeCommit

public void setWaitBeforeCommit(boolean waitBeforeCommit)

Specified by:

setWaitBeforeCommit in interface Transaction

getXid

public Xid getXid()

Specified by:

getXid in interface Transaction

markAsRollbackOnly

public void markAsRollbackOnly(HornetQException exception1)

Specified by:

markAsRollbackOnly in interface Transaction

addOperation

public void addOperation(TransactionOperation operation)

Specified by:

addOperation in interface Transaction

getAllOperations

public List<TransactionOperation> getAllOperations()

Specified by:

getAllOperations in interface Transaction

putProperty

public void putProperty(int index,
               Object property)

Specified by:

putProperty in interface Transaction

getProperty

public Object getProperty(int index)

Specified by:

getProperty in interface Transaction

toString

public String toString()

Overrides:

toString in class Object