Package org.apache.activemq.store.kahadb
Class KahaDBTransactionStore
- java.lang.Object
-
- org.apache.activemq.store.kahadb.KahaDBTransactionStore
-
- All Implemented Interfaces:
Service
,TransactionStore
public class KahaDBTransactionStore extends Object implements 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 class
KahaDBTransactionStore.AddMessageCommand
class
KahaDBTransactionStore.RemoveMessageCommand
class
KahaDBTransactionStore.Tx
-
Constructor Summary
Constructors Constructor Description KahaDBTransactionStore(KahaDBStore theStore)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit)
protected void
forgetRecoveredAcks(TransactionId txid, boolean isRollback)
KahaDBTransactionStore.Tx
getTx(Object txid)
void
prepare(TransactionId txid)
MessageStore
proxy(MessageStore messageStore)
TopicMessageStore
proxy(TopicMessageStore messageStore)
void
recover(TransactionRecoveryListener listener)
void
rollback(TransactionId txid)
void
start()
void
stop()
-
-
-
Constructor Detail
-
KahaDBTransactionStore
public KahaDBTransactionStore(KahaDBStore theStore)
-
-
Method Detail
-
proxy
public MessageStore proxy(MessageStore messageStore)
-
proxy
public TopicMessageStore proxy(TopicMessageStore messageStore)
-
prepare
public void prepare(TransactionId txid) throws IOException
- Specified by:
prepare
in interfaceTransactionStore
- Throws:
IOException
- See Also:
TransactionStore.prepare(TransactionId)
-
getTx
public KahaDBTransactionStore.Tx getTx(Object txid)
-
commit
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
- Specified by:
commit
in interfaceTransactionStore
- Throws:
IOException
-
rollback
public void rollback(TransactionId txid) throws IOException
- Specified by:
rollback
in interfaceTransactionStore
- Throws:
IOException
- See Also:
TransactionStore.rollback(TransactionId)
-
forgetRecoveredAcks
protected void forgetRecoveredAcks(TransactionId txid, boolean isRollback) throws IOException
- Throws:
IOException
-
start
public void start() throws Exception
-
recover
public void recover(TransactionRecoveryListener listener) throws IOException
- Specified by:
recover
in interfaceTransactionStore
- Throws:
IOException
-
-