Package org.apache.activemq.store.kahadb

Class KahaDBTransactionStore

java.lang.Object

org.apache.activemq.store.kahadb.KahaDBTransactionStore

All Implemented Interfaces:

org.apache.activemq.Service, org.apache.activemq.store.TransactionStore

public class KahaDBTransactionStore
extends Object
implements org.apache.activemq.store.TransactionStore

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KahaDBTransactionStore.AddMessageCommand
static class	KahaDBTransactionStore.RemoveMessageCommand
class	KahaDBTransactionStore.Tx

Constructor Summary

Constructors

Constructor	Description
KahaDBTransactionStore(KahaDBStore theStore)

Method Summary

Modifier and Type	Method	Description
void	commit(org.apache.activemq.command.TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit)
protected void	forgetRecoveredAcks(org.apache.activemq.command.TransactionId txid, boolean isRollback)
void	prepare(org.apache.activemq.command.TransactionId txid)
org.apache.activemq.store.MessageStore	proxy(org.apache.activemq.store.MessageStore messageStore)
org.apache.activemq.store.TopicMessageStore	proxy(org.apache.activemq.store.TopicMessageStore messageStore)
void	recover(org.apache.activemq.store.TransactionRecoveryListener listener)
void	rollback(org.apache.activemq.command.TransactionId txid)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

KahaDBTransactionStore

public KahaDBTransactionStore(KahaDBStore theStore)

Method Details

proxy

public org.apache.activemq.store.MessageStore proxy(org.apache.activemq.store.MessageStore messageStore)

proxy

public org.apache.activemq.store.TopicMessageStore proxy(org.apache.activemq.store.TopicMessageStore messageStore)

prepare

public void prepare(org.apache.activemq.command.TransactionId txid)
             throws IOException

Specified by:

prepare in interface org.apache.activemq.store.TransactionStore

Throws:

IOException

See Also:

• TransactionStore.prepare(TransactionId)

commit

public void commit(org.apache.activemq.command.TransactionId txid,
 boolean wasPrepared,
 Runnable preCommit,
 Runnable postCommit)
            throws IOException

Specified by:

commit in interface org.apache.activemq.store.TransactionStore

Throws:

IOException

rollback

public void rollback(org.apache.activemq.command.TransactionId txid)
              throws IOException

Specified by:

rollback in interface org.apache.activemq.store.TransactionStore

Throws:

IOException

See Also:

• TransactionStore.rollback(TransactionId)

forgetRecoveredAcks

protected void forgetRecoveredAcks(org.apache.activemq.command.TransactionId txid,
 boolean isRollback)
                            throws IOException

Throws:

IOException

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.Service

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.Service

Throws:

Exception

recover

public void recover(org.apache.activemq.store.TransactionRecoveryListener listener)
             throws IOException

Specified by:

recover in interface org.apache.activemq.store.TransactionStore

Throws:

IOException