Package org.apache.activemq.store.kahadb
Class MultiKahaDBTransactionStore
- java.lang.Object
-
- org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- All Implemented Interfaces:
Service
,TransactionStore
public class MultiKahaDBTransactionStore extends Object implements TransactionStore
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
MultiKahaDBTransactionStore.Tx
-
Constructor Summary
Constructors Constructor Description MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter)
-
Method Summary
-
-
-
Constructor Detail
-
MultiKahaDBTransactionStore
public MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter)
-
-
Method Detail
-
proxy
public MessageStore proxy(TransactionStore transactionStore, MessageStore messageStore)
-
proxy
public TopicMessageStore proxy(TransactionStore transactionStore, TopicMessageStore messageStore)
-
deleteAllMessages
public void deleteAllMessages()
-
getJournalMaxFileLength
public int getJournalMaxFileLength()
-
setJournalMaxFileLength
public void setJournalMaxFileLength(int journalMaxFileLength)
-
getJournalMaxWriteBatchSize
public int getJournalMaxWriteBatchSize()
-
setJournalMaxWriteBatchSize
public void setJournalMaxWriteBatchSize(int journalWriteBatchSize)
-
setJournalCleanupInterval
public void setJournalCleanupInterval(long journalCleanupInterval)
-
getJournalCleanupInterval
public long getJournalCleanupInterval()
-
setCheckForCorruption
public void setCheckForCorruption(boolean checkForCorruption)
-
isCheckForCorruption
public boolean isCheckForCorruption()
-
getTx
public MultiKahaDBTransactionStore.Tx getTx(TransactionId txid)
-
removeTx
public MultiKahaDBTransactionStore.Tx removeTx(TransactionId txid)
-
prepare
public void prepare(TransactionId txid) throws IOException
- Specified by:
prepare
in interfaceTransactionStore
- Throws:
IOException
-
commit
public void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit) throws IOException
- Specified by:
commit
in interfaceTransactionStore
- Throws:
IOException
-
persistOutcome
public void persistOutcome(MultiKahaDBTransactionStore.Tx tx, TransactionId txid) throws IOException
- Throws:
IOException
-
persistCompletion
public void persistCompletion(TransactionId txid) throws IOException
- Throws:
IOException
-
rollback
public void rollback(TransactionId txid) throws IOException
- Specified by:
rollback
in interfaceTransactionStore
- Throws:
IOException
-
start
public void start() throws Exception
-
load
public JournalCommand<?> load(Location location) throws IOException
- Throws:
IOException
-
process
public void process(Location location, JournalCommand<?> command) throws IOException
- Throws:
IOException
-
recover
public void recover(TransactionRecoveryListener listener) throws IOException
- Specified by:
recover
in interfaceTransactionStore
- Throws:
IOException
-
-