org.hornetq.core.transaction.impl

Class TransactionImpl

java.lang.Object

org.hornetq.core.transaction.impl.TransactionImpl

All Implemented Interfaces:

Transaction

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

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)
void	afterCommit()
void	afterPrepare()
void	afterRollback()
protected void	asyncAppendCommit()
void	beforeCommit()
void	beforePrepare()
void	beforeRollback()
void	commit()
void	commit(boolean onePhase)
Transaction	copy() Used for pages during commit.
List<TransactionOperation>	getAllOperations()
long	getCreateTime()
long	getID()
int	getOperationsCount()
Object	getProperty(int index)
Transaction.State	getState()
Xid	getXid()
boolean	hasTimedOut(long currentTime, int defaultTimeout)
boolean	isContainsPersistent()
boolean	isWaitBeforeCommit()
void	markAsRollbackOnly(HornetQException exception)
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()

Methods inherited from class java.lang.Object

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

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

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

isWaitBeforeCommit

public boolean isWaitBeforeCommit()

Specified by:

isWaitBeforeCommit 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 exception)

Specified by:

markAsRollbackOnly in interface Transaction

addOperation

public void addOperation(TransactionOperation operation)

Specified by:

addOperation in interface Transaction

getOperationsCount

public int getOperationsCount()

Specified by:

getOperationsCount 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

copy

public Transaction copy()

Description copied from interface: Transaction

Used for pages during commit. When paging messages we need to guarantee that they are in the same transaction (but not with the same set of TransactionOperation).

Specified by:

copy in interface Transaction

afterCommit

public void afterCommit()

Specified by:

afterCommit in interface Transaction

afterRollback

public void afterRollback()

Specified by:

afterRollback in interface Transaction

beforeCommit

public void beforeCommit()
                  throws Exception

Specified by:

beforeCommit in interface Transaction

Throws:

Exception

beforePrepare

public void beforePrepare()
                   throws Exception

Specified by:

beforePrepare in interface Transaction

Throws:

Exception

beforeRollback

public void beforeRollback()
                    throws Exception

Specified by:

beforeRollback in interface Transaction

Throws:

Exception

afterPrepare

public void afterPrepare()

Specified by:

afterPrepare in interface Transaction