org.apache.activemq.store.kahadb
Class KahaDBTransactionStore

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

public class KahaDBTransactionStore
extends Object
implements TransactionStore

Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects.


Nested Class Summary
 class KahaDBTransactionStore.AddMessageCommand
           
 class KahaDBTransactionStore.RemoveMessageCommand
           
 class KahaDBTransactionStore.Tx
           
 
Constructor Summary
KahaDBTransactionStore(KahaDBStore theStore)
           
 
Method Summary
 void commit(TransactionId txid, boolean wasPrepared, Runnable preCommit, Runnable postCommit)
           
protected  void forgetRecoveredAcks(TransactionId txid)
           
 KahaDBTransactionStore.Tx getTx(Object txid)
           
 void prepare(TransactionId txid)
           
 MessageStore proxy(MessageStore messageStore)
           
 TopicMessageStore proxy(TopicMessageStore messageStore)
           
 void recover(TransactionRecoveryListener listener)
           
 void rollback(TransactionId txid)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

KahaDBTransactionStore

public KahaDBTransactionStore(KahaDBStore theStore)
Method Detail

proxy

public MessageStore proxy(MessageStore messageStore)

proxy

public TopicMessageStore proxy(TopicMessageStore messageStore)

prepare

public void prepare(TransactionId txid)
             throws IOException
Specified by:
prepare in interface TransactionStore
Throws:
IOException
See Also:
TransactionStore.prepare(TransactionId)

getTx

public KahaDBTransactionStore.Tx getTx(Object txid)

commit

public void commit(TransactionId txid,
                   boolean wasPrepared,
                   Runnable preCommit,
                   Runnable postCommit)
            throws IOException
Specified by:
commit in interface TransactionStore
Throws:
IOException

rollback

public void rollback(TransactionId txid)
              throws IOException
Specified by:
rollback in interface TransactionStore
Throws:
IOException
See Also:
TransactionStore.rollback(TransactionId)

forgetRecoveredAcks

protected void forgetRecoveredAcks(TransactionId txid)
                            throws IOException
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

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.