org.hornetq.core.transaction

Interface Transaction

All Known Implementing Classes:

BindingsTransactionImpl, TransactionImpl

public interface Transaction

A HornetQ internal transaction

Author:

Tim Fox,

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Transaction.State

Method Summary

Methods

Modifier and Type	Method and Description
void	addOperation(TransactionOperation sync)
void	afterStore(TransactionOperation sync) This is an operation that will be called right after the storage is completed.
void	commit()
void	commit(boolean onePhase)
List<TransactionOperation>	getAllOperations()
long	getCreateTime()
long	getID()
Object	getProperty(int index)
Transaction.State	getState()
Xid	getXid()
boolean	hasTimedOut(long currentTime, int defaultTimeout)
boolean	isContainsPersistent()
boolean	isEffective()
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	suspend()

Method Detail

isEffective

boolean isEffective()

prepare

void prepare()
             throws Exception

Throws:

Exception

commit

void commit()
            throws Exception

Throws:

Exception

commit

void commit(boolean onePhase)
            throws Exception

Throws:

Exception

rollback

void rollback()
              throws Exception

Throws:

Exception

getID

long getID()

getXid

Xid getXid()

suspend

void suspend()

resume

void resume()

getState

Transaction.State getState()

setState

void setState(Transaction.State state)

markAsRollbackOnly

void markAsRollbackOnly(HornetQException exception)

getCreateTime

long getCreateTime()

addOperation

void addOperation(TransactionOperation sync)

afterStore

void afterStore(TransactionOperation sync)

This is an operation that will be called right after the storage is completed. addOperation could only happen after paging and replication, while these operations will just be about the storage

getAllOperations

List<TransactionOperation> getAllOperations()

hasTimedOut

boolean hasTimedOut(long currentTime,
                  int defaultTimeout)

putProperty

void putProperty(int index,
               Object property)

getProperty

Object getProperty(int index)

isContainsPersistent

boolean isContainsPersistent()

setContainsPersistent

void setContainsPersistent()

setTimeout

void setTimeout(int timeout)