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(org.apache.activemq.command.TransactionId txid,
boolean wasPrepared,
Runnable preCommit,
Runnable postCommit) |
void |
deleteAllMessages() |
long |
getJournalCleanupInterval() |
int |
getJournalMaxFileLength() |
int |
getJournalMaxWriteBatchSize() |
MultiKahaDBTransactionStore.Tx |
getTx(org.apache.activemq.command.TransactionId txid) |
boolean |
isCheckForCorruption() |
JournalCommand<?> |
load(Location location) |
void |
persistCompletion(org.apache.activemq.command.TransactionId txid) |
void |
persistOutcome(MultiKahaDBTransactionStore.Tx tx,
org.apache.activemq.command.TransactionId txid) |
void |
prepare(org.apache.activemq.command.TransactionId txid) |
void |
process(Location location,
JournalCommand<?> command) |
MessageStore |
proxy(TransactionStore transactionStore,
MessageStore messageStore) |
TopicMessageStore |
proxy(TransactionStore transactionStore,
TopicMessageStore messageStore) |
void |
recover(TransactionRecoveryListener listener) |
MultiKahaDBTransactionStore.Tx |
removeTx(org.apache.activemq.command.TransactionId txid) |
void |
rollback(org.apache.activemq.command.TransactionId txid) |
void |
setCheckForCorruption(boolean checkForCorruption) |
void |
setJournalCleanupInterval(long journalCleanupInterval) |
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 void setJournalCleanupInterval(long journalCleanupInterval)
public long getJournalCleanupInterval()
public void setCheckForCorruption(boolean checkForCorruption)
public boolean isCheckForCorruption()
public MultiKahaDBTransactionStore.Tx getTx(org.apache.activemq.command.TransactionId txid)
public MultiKahaDBTransactionStore.Tx removeTx(org.apache.activemq.command.TransactionId txid)
public void prepare(org.apache.activemq.command.TransactionId txid) throws IOException
prepare
in interface TransactionStore
IOException
public void commit(org.apache.activemq.command.TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
commit
in interface TransactionStore
IOException
public void persistOutcome(MultiKahaDBTransactionStore.Tx tx, org.apache.activemq.command.TransactionId txid) throws IOException
IOException
public void persistCompletion(org.apache.activemq.command.TransactionId txid) throws IOException
IOException
public void rollback(org.apache.activemq.command.TransactionId txid) throws IOException
rollback
in interface TransactionStore
IOException
public void start() throws Exception
start
in interface org.apache.activemq.Service
Exception
public void stop() throws Exception
stop
in interface org.apache.activemq.Service
Exception
public JournalCommand<?> load(Location location) throws IOException
IOException
public void process(Location location, JournalCommand<?> command) throws IOException
IOException
public void recover(TransactionRecoveryListener listener) throws IOException
recover
in interface TransactionStore
IOException
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.