org.apache.activemq.store.kahadaptor
Class KahaTransactionStore

java.lang.Object
  extended by org.apache.activemq.store.kahadaptor.KahaTransactionStore
All Implemented Interfaces:
BrokerServiceAware, Service, TransactionStore

public class KahaTransactionStore
extends Object
implements TransactionStore, BrokerServiceAware

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


Method Summary
 void commit(TransactionId txid, boolean wasPrepared, Runnable before, Runnable after)
           
 void delete()
           
protected  org.apache.activemq.store.kahadaptor.KahaTransaction getOrCreateTx(TransactionId key)
           
protected  MessageStore getStoreById(Object id)
           
protected  org.apache.activemq.store.kahadaptor.KahaTransaction getTx(TransactionId key)
           
 void prepare(TransactionId txid)
           
 MessageStore proxy(MessageStore messageStore)
           
 TopicMessageStore proxy(TopicMessageStore messageStore)
           
 void recover(TransactionRecoveryListener listener)
           
protected  void removeTx(TransactionId key)
           
 void rollback(TransactionId txid)
           
 void setBrokerService(BrokerService brokerService)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

proxy

public MessageStore proxy(MessageStore messageStore)

proxy

public TopicMessageStore proxy(TopicMessageStore messageStore)

prepare

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

commit

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

rollback

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

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

getTx

protected org.apache.activemq.store.kahadaptor.KahaTransaction getTx(TransactionId key)

getOrCreateTx

protected org.apache.activemq.store.kahadaptor.KahaTransaction getOrCreateTx(TransactionId key)

removeTx

protected void removeTx(TransactionId key)

delete

public void delete()

getStoreById

protected MessageStore getStoreById(Object id)

setBrokerService

public void setBrokerService(BrokerService brokerService)
Specified by:
setBrokerService in interface BrokerServiceAware


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