org.apache.activemq.store.kahadb
Class MultiKahaDBTransactionStore

java.lang.Object
  extended by org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
All Implemented Interfaces:
Service, TransactionStore

public class MultiKahaDBTransactionStore
extends Object
implements TransactionStore


Nested Class Summary
 class MultiKahaDBTransactionStore.Tx
           
 
Constructor Summary
MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter)
           
 
Method Summary
 void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, 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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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)

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 interface TransactionStore
Throws:
IOException

commit

public void commit(TransactionId txid,
                   boolean wasPrepared,
                   Runnable preCommit,
                   Runnable postCommit)
            throws IOException
Specified by:
commit in interface TransactionStore
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 interface TransactionStore
Throws:
IOException

start

public void start()
           throws Exception
Specified by:
start in interface Service
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Throws:
Exception

load

public JournalCommand<?> load(Location location)
                       throws IOException
Throws:
IOException

process

public void process(JournalCommand<?> command)
             throws IOException
Throws:
IOException

recover

public void recover(TransactionRecoveryListener listener)
             throws IOException
Specified by:
recover in interface TransactionStore
Throws:
IOException


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.