org.apache.activemq.store.kahadaptor

Class KahaTransactionStore

java.lang.Object

org.apache.activemq.store.kahadaptor.KahaTransactionStore

All Implemented Interfaces:

BrokerServiceAware, Service, TransactionStore

public class KahaTransactionStore
extends Object
implements TransactionStore, BrokerServiceAware

Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects.

Method Summary

Methods

Modifier and Type	Method and Description
void	commit(TransactionId txid, boolean wasPrepared, Runnable before, Runnable after)
void	delete()
protected org.apache.activemq.store.kahadaptor.KahaTransaction	getOrCreateTx(TransactionId key)
protected MessageStore	getStoreById(Object id)
protected org.apache.activemq.store.kahadaptor.KahaTransaction	getTx(TransactionId key)
void	prepare(TransactionId txid)
MessageStore	proxy(MessageStore messageStore)
TopicMessageStore	proxy(TopicMessageStore messageStore)
void	recover(TransactionRecoveryListener listener)
protected void	removeTx(TransactionId key)
void	rollback(TransactionId txid)
void	setBrokerService(BrokerService brokerService)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Method Detail

proxy

public MessageStore proxy(MessageStore messageStore)

proxy

public TopicMessageStore proxy(TopicMessageStore messageStore)

prepare

public void prepare(TransactionId txid)

Specified by:

prepare in interface TransactionStore

See Also:

TransactionStore.prepare(TransactionId)

commit

public void commit(TransactionId txid,
          boolean wasPrepared,
          Runnable before,
          Runnable after)
            throws IOException

Specified by:

commit in interface TransactionStore

Throws:

IOException

rollback

public void rollback(TransactionId txid)

Specified by:

rollback in interface TransactionStore

See Also:

TransactionStore.rollback(TransactionId)

start

public void start()
           throws Exception

Specified by:

start in interface Service

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Throws:

Exception

recover

public void recover(TransactionRecoveryListener listener)
             throws IOException

Specified by:

recover in interface TransactionStore

Throws:

IOException

getTx

protected org.apache.activemq.store.kahadaptor.KahaTransaction getTx(TransactionId key)

getOrCreateTx

protected org.apache.activemq.store.kahadaptor.KahaTransaction getOrCreateTx(TransactionId key)

removeTx

protected void removeTx(TransactionId key)

delete

public void delete()

getStoreById

protected MessageStore getStoreById(Object id)

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware