public class KahaDBTransactionStore extends java.lang.Object implements TransactionStore
Modifier and Type | Class and Description |
---|---|
class |
KahaDBTransactionStore.AddMessageCommand |
class |
KahaDBTransactionStore.RemoveMessageCommand |
class |
KahaDBTransactionStore.Tx |
Constructor and Description |
---|
KahaDBTransactionStore(KahaDBStore theStore) |
Modifier and Type | Method and Description |
---|---|
void |
commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit) |
KahaDBTransactionStore.Tx |
getTx(java.lang.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() |
public KahaDBTransactionStore(KahaDBStore theStore)
public MessageStore proxy(MessageStore messageStore)
public TopicMessageStore proxy(TopicMessageStore messageStore)
public void prepare(TransactionId txid) throws java.io.IOException
prepare
in interface TransactionStore
java.io.IOException
TransactionStore.prepare(TransactionId)
public KahaDBTransactionStore.Tx getTx(java.lang.Object txid)
public void commit(TransactionId txid, boolean wasPrepared, java.lang.Runnable preCommit, java.lang.Runnable postCommit) throws java.io.IOException
commit
in interface TransactionStore
java.io.IOException
public void rollback(TransactionId txid) throws java.io.IOException
rollback
in interface TransactionStore
java.io.IOException
TransactionStore.rollback(TransactionId)
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public void recover(TransactionRecoveryListener listener) throws java.io.IOException
recover
in interface TransactionStore
java.io.IOException
Copyright © 2005-2012. All Rights Reserved.