public class MultiKahaDBTransactionStore extends Object implements TransactionStore
Modifier and Type | Class and Description |
---|---|
class |
MultiKahaDBTransactionStore.Tx |
Constructor and Description |
---|
MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
commit(TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
deleteAllMessages() |
int |
getJournalMaxFileLength() |
int |
getJournalMaxWriteBatchSize() |
MultiKahaDBTransactionStore.Tx |
getTx(TransactionId txid) |
JournalCommand<?> |
load(Location location) |
void |
persistCompletion(TransactionId txid) |
void |
persistOutcome(MultiKahaDBTransactionStore.Tx tx,
TransactionId txid) |
void |
prepare(TransactionId txid) |
void |
process(JournalCommand<?> command) |
MessageStore |
proxy(TransactionStore transactionStore,
MessageStore messageStore) |
TopicMessageStore |
proxy(TransactionStore transactionStore,
TopicMessageStore messageStore) |
void |
recover(TransactionRecoveryListener listener) |
MultiKahaDBTransactionStore.Tx |
removeTx(TransactionId txid) |
void |
rollback(TransactionId txid) |
void |
setJournalMaxFileLength(int journalMaxFileLength) |
void |
setJournalMaxWriteBatchSize(int journalWriteBatchSize) |
void |
start() |
void |
stop() |
public MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter)
public MessageStore proxy(TransactionStore transactionStore, MessageStore messageStore)
public TopicMessageStore proxy(TransactionStore transactionStore, TopicMessageStore messageStore)
public void deleteAllMessages()
public int getJournalMaxFileLength()
public void setJournalMaxFileLength(int journalMaxFileLength)
public int getJournalMaxWriteBatchSize()
public void setJournalMaxWriteBatchSize(int journalWriteBatchSize)
public MultiKahaDBTransactionStore.Tx getTx(TransactionId txid)
public MultiKahaDBTransactionStore.Tx removeTx(TransactionId txid)
public void prepare(TransactionId txid) throws IOException
prepare
in interface TransactionStore
IOException
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
IOException
public void persistOutcome(MultiKahaDBTransactionStore.Tx tx, TransactionId txid) throws IOException
IOException
public void persistCompletion(TransactionId txid) throws IOException
IOException
public void rollback(TransactionId txid) throws IOException
rollback
in interface TransactionStore
IOException
public JournalCommand<?> load(Location location) throws IOException
IOException
public void process(JournalCommand<?> command) throws IOException
IOException
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
Copyright © 2005–2017. All rights reserved.