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

All Implemented Interfaces:
    PersistenceAdapter

Field Summary
 MemoryTransactionStore transactionStore     
 ConcurrentHashMap<ActiveMQDestination, TopicMessageStore> topics     
 ConcurrentHashMap<ActiveMQDestination, MessageStore> queues     
Method from org.apache.activemq.store.memory.MemoryPersistenceAdapter Summary:
asMemoryMessageStore,   beginTransaction,   checkpoint,   commitTransaction,   createQueueMessageStore,   createTopicMessageStore,   createTransactionStore,   deleteAllMessages,   getDestinations,   getLastMessageBrokerSequenceId,   isUseExternalMessageReferences,   newInstance,   removeQueueMessageStore,   removeTopicMessageStore,   rollbackTransaction,   setBrokerName,   setCreateTransactionStore,   setDirectory,   setUsageManager,   setUseExternalMessageReferences,   size,   start,   stop,   toString
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.store.memory.MemoryPersistenceAdapter Detail:
 protected MemoryMessageStore asMemoryMessageStore(Object value) 
 public  void beginTransaction(ConnectionContext context) 
 public  void checkpoint(boolean sync) throws IOException 
 public  void commitTransaction(ConnectionContext context) 
 public MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException 
 public TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException 
 public TransactionStore createTransactionStore() throws IOException 
 public  void deleteAllMessages() throws IOException 
 public Set<ActiveMQDestination> getDestinations() 
 public long getLastMessageBrokerSequenceId() throws IOException 
 public boolean isUseExternalMessageReferences() 
 public static MemoryPersistenceAdapter newInstance(File file) 
 public  void removeQueueMessageStore(ActiveMQQueue destination) 
    Cleanup method to remove any state associated with the given destination
 public  void removeTopicMessageStore(ActiveMQTopic destination) 
    Cleanup method to remove any state associated with the given destination
 public  void rollbackTransaction(ConnectionContext context) 
 public  void setBrokerName(String brokerName) 
 public  void setCreateTransactionStore(boolean create) throws IOException 
 public  void setDirectory(File dir) 
 public  void setUsageManager(SystemUsage usageManager) 
 public  void setUseExternalMessageReferences(boolean useExternalMessageReferences) 
 public long size() 
 public  void start() throws Exception 
 public  void stop() throws Exception 
 public String toString()