Home » activemq-parent-5.3.1-source-release » org.apache » activemq » store » memory » [javadoc | source]
org.apache.activemq.store.memory
public class: MemoryTransactionStore [javadoc | source]
java.lang.Object
   org.apache.activemq.store.memory.MemoryTransactionStore

All Implemented Interfaces:
    TransactionStore

Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects.
Nested Class Summary:
public class  MemoryTransactionStore.Tx   
public interface  MemoryTransactionStore.AddMessageCommand   
public interface  MemoryTransactionStore.RemoveMessageCommand   
Field Summary
 ConcurrentHashMap<Object, Tx> inflightTransactions     
 ConcurrentHashMap<TransactionId, Tx> preparedTransactions     
final  PersistenceAdapter persistenceAdapter     
Constructor:
 public MemoryTransactionStore(PersistenceAdapter persistenceAdapter) 
Method from org.apache.activemq.store.memory.MemoryTransactionStore Summary:
addMessage,   commit,   delete,   getTx,   prepare,   proxy,   proxy,   recover,   removeMessage,   rollback,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.memory.MemoryTransactionStore Detail:
  void addMessage(MessageStore destination,
    Message message) throws IOException 
 public  void commit(TransactionId txid,
    boolean wasPrepared) throws IOException 
 public  void delete() 
 public Tx getTx(Object txid) 
 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 
 public  void rollback(TransactionId txid) 
 public  void start() throws Exception 
 public  void stop() throws Exception