public class MultiKahaDBTransactionStore extends Object implements TransactionStore
Modifier and Type | Class and Description |
---|---|
class |
MultiKahaDBTransactionStore.Tx |
Constructor and Description |
---|
MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter) |
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 void start() throws Exception
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 The Apache Software Foundation. All rights reserved.