Package org.apache.activemq.artemis.core.transaction

Class TransactionOperationAbstract

java.lang.Object

org.apache.activemq.artemis.core.transaction.TransactionOperationAbstract

All Implemented Interfaces:

TransactionOperation

Direct Known Subclasses:

FinishPageMessageOperation, RefsOperation, TXLargeMessageConfirmationOperation

public abstract class TransactionOperationAbstract
extends Object
implements TransactionOperation

Just a helper, when you don't want to implement all the methods on a transaction operation.

Constructor Summary

Constructors

Constructor	Description
TransactionOperationAbstract()

Method Summary

Modifier and Type	Method	Description
static TransactionOperationAbstract	afterCommit(Runnable run)
void	afterCommit(Transaction tx)	After commit shouldn't throw any exception.
void	afterPrepare(Transaction tx)	After prepare shouldn't throw any exception.
void	afterRollback(Transaction tx)	After rollback shouldn't throw any exception.
void	beforeCommit(Transaction tx)
void	beforePrepare(Transaction tx)
void	beforeRollback(Transaction tx)
List<MessageReference>	getListOnConsumer(long consumerID)
List<MessageReference>	getRelatedMessageReferences()

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionOperationAbstract

public TransactionOperationAbstract()

Method Details

afterCommit

public static TransactionOperationAbstract afterCommit(Runnable run)

beforePrepare

public void beforePrepare(Transaction tx)
                   throws Exception

Specified by:

beforePrepare in interface TransactionOperation

Throws:

Exception

afterPrepare

public void afterPrepare(Transaction tx)

After prepare shouldn't throw any exception.

Any verification has to be done on before prepare

Specified by:

afterPrepare in interface TransactionOperation

beforeCommit

public void beforeCommit(Transaction tx)
                  throws Exception

Specified by:

beforeCommit in interface TransactionOperation

Throws:

Exception

afterCommit

public void afterCommit(Transaction tx)

After commit shouldn't throw any exception.

Any verification has to be done on before commit

Specified by:

afterCommit in interface TransactionOperation

beforeRollback

public void beforeRollback(Transaction tx)
                    throws Exception

Specified by:

beforeRollback in interface TransactionOperation

Throws:

Exception

afterRollback

public void afterRollback(Transaction tx)

After rollback shouldn't throw any exception.

Any verification has to be done on before rollback

Specified by:

afterRollback in interface TransactionOperation

getRelatedMessageReferences

public List<MessageReference> getRelatedMessageReferences()

Specified by:

getRelatedMessageReferences in interface TransactionOperation

getListOnConsumer

public List<MessageReference> getListOnConsumer(long consumerID)

Specified by:

getListOnConsumer in interface TransactionOperation