public class KahaDBTransactionStore extends 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,
Runnable preCommit,
Runnable postCommit) |
protected void |
forgetRecoveredAcks(TransactionId txid) |
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() |
public KahaDBTransactionStore(KahaDBStore theStore)
public MessageStore proxy(MessageStore messageStore)
public TopicMessageStore proxy(TopicMessageStore messageStore)
public void prepare(TransactionId txid) throws IOException
prepare
in interface TransactionStore
IOException
TransactionStore.prepare(TransactionId)
public KahaDBTransactionStore.Tx getTx(Object txid)
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
IOException
public void rollback(TransactionId txid) throws IOException
rollback
in interface TransactionStore
IOException
TransactionStore.rollback(TransactionId)
protected void forgetRecoveredAcks(TransactionId txid) throws IOException
IOException
public void start() throws Exception
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.