public class MultiKahaDBTransactionStore extends java.lang.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,
java.lang.Runnable preCommit,
java.lang.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 java.io.IOException
prepare
in interface TransactionStore
java.io.IOException
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 persistOutcome(MultiKahaDBTransactionStore.Tx tx, TransactionId txid) throws java.io.IOException
java.io.IOException
public void persistCompletion(TransactionId txid) throws java.io.IOException
java.io.IOException
public void rollback(TransactionId txid) throws java.io.IOException
rollback
in interface TransactionStore
java.io.IOException
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public JournalCommand<?> load(Location location) throws java.io.IOException
java.io.IOException
public void process(JournalCommand<?> command) throws java.io.IOException
java.io.IOException
public void recover(TransactionRecoveryListener listener) throws java.io.IOException
recover
in interface TransactionStore
java.io.IOException
Copyright © 2005-2017. All Rights Reserved.