Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » kahadaptor » [javadoc | source]
org.apache.activemq.store.kahadaptor
public class: KahaTransactionStore [javadoc | source]
java.lang.Object
   org.apache.activemq.store.kahadaptor.KahaTransactionStore

All Implemented Interfaces:
    TransactionStore, BrokerServiceAware

Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects.
Constructor:
 KahaTransactionStore(KahaPersistenceAdapter adaptor,
    Map preparedMap) 
Method from org.apache.activemq.store.kahadaptor.KahaTransactionStore Summary:
addMessage,   commit,   delete,   getOrCreateTx,   getStoreById,   getTx,   prepare,   proxy,   proxy,   recover,   removeMessage,   removeTx,   rollback,   setBrokerService,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.kahadaptor.KahaTransactionStore Detail:
  void addMessage(MessageStore destination,
    Message message) throws IOException 
 public  void commit(TransactionId txid,
    boolean wasPrepared) throws IOException 
 public  void delete() 
 protected synchronized KahaTransaction getOrCreateTx(TransactionId key) 
 protected MessageStore getStoreById(Object id) 
 protected synchronized KahaTransaction getTx(TransactionId key) 
 public  void prepare(TransactionId txid) 
 public MessageStore proxy(MessageStore messageStore) 
 public TopicMessageStore proxy(TopicMessageStore messageStore) 
 public synchronized  void recover(TransactionRecoveryListener listener) throws IOException 
 final  void removeMessage(MessageStore destination,
    MessageAck ack) throws IOException 
 protected synchronized  void removeTx(TransactionId key) 
 public  void rollback(TransactionId txid) 
 public  void setBrokerService(BrokerService brokerService) 
 public  void start() throws Exception 
 public  void stop() throws Exception