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 java.lang.Object
- implements TransactionStore
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MultiKahaDBTransactionStore
public MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter)
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)
getTx
public MultiKahaDBTransactionStore.Tx getTx(TransactionId txid)
removeTx
public MultiKahaDBTransactionStore.Tx removeTx(TransactionId txid)
prepare
public void prepare(TransactionId txid)
throws java.io.IOException
- Specified by:
prepare
in interface TransactionStore
- Throws:
java.io.IOException
commit
public void commit(TransactionId txid,
boolean wasPrepared,
java.lang.Runnable preCommit,
java.lang.Runnable postCommit)
throws java.io.IOException
- Specified by:
commit
in interface TransactionStore
- Throws:
java.io.IOException
persistOutcome
public void persistOutcome(MultiKahaDBTransactionStore.Tx tx,
TransactionId txid)
throws java.io.IOException
- Throws:
java.io.IOException
persistCompletion
public void persistCompletion(TransactionId txid)
throws java.io.IOException
- Throws:
java.io.IOException
rollback
public void rollback(TransactionId txid)
throws java.io.IOException
- Specified by:
rollback
in interface TransactionStore
- Throws:
java.io.IOException
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Throws:
java.lang.Exception
load
public JournalCommand<?> load(Location location)
throws java.io.IOException
- Throws:
java.io.IOException
process
public void process(JournalCommand<?> command)
throws java.io.IOException
- Throws:
java.io.IOException
recover
public void recover(TransactionRecoveryListener listener)
throws java.io.IOException
- Specified by:
recover
in interface TransactionStore
- Throws:
java.io.IOException
Copyright © 2005-2016. All Rights Reserved.