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: KahaPersistenceAdapter [javadoc | source]
java.lang.Object
   org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter

All Implemented Interfaces:
    BrokerServiceAware, PersistenceAdapter

Direct Known Subclasses:
    KahaReferenceStoreAdapter

Field Summary
protected  OpenWireFormat wireFormat     
protected  KahaTransactionStore transactionStore     
protected  ConcurrentHashMap<ActiveMQTopic, TopicMessageStore> topics     
protected  ConcurrentHashMap<ActiveMQQueue, MessageStore> queues     
protected  ConcurrentHashMap<ActiveMQDestination, MessageStore> messageStores     
Constructor:
 public KahaPersistenceAdapter() 
 public KahaPersistenceAdapter(AtomicLong size) 
Method from org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter Summary:
beginTransaction,   checkpoint,   commitTransaction,   createMessageMarshaller,   createQueueMessageStore,   createStore,   createTopicMessageStore,   createTransactionStore,   deleteAllMessages,   getBrokerName,   getDestinations,   getDirectory,   getLastMessageBrokerSequenceId,   getListContainer,   getMapContainer,   getMaxDataFileLength,   getStore,   getSubsMapContainer,   isPersistentIndex,   removeQueueMessageStore,   removeTopicMessageStore,   retrieveMessageStore,   rollbackTransaction,   setBrokerName,   setBrokerService,   setDirectory,   setMaxDataFileLength,   setPersistentIndex,   setUsageManager,   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.kahadaptor.KahaPersistenceAdapter Detail:
 public  void beginTransaction(ConnectionContext context) 
 public  void checkpoint(boolean sync) throws IOException 
 public  void commitTransaction(ConnectionContext context) throws IOException 
 protected Marshaller<Object> createMessageMarshaller() 
 public synchronized MessageStore createQueueMessageStore(ActiveMQQueue destination) throws IOException 
 protected final Store createStore() throws IOException 
 public synchronized TopicMessageStore createTopicMessageStore(ActiveMQTopic destination) throws IOException 
 public TransactionStore createTransactionStore() throws IOException 
 public  void deleteAllMessages() throws IOException 
 public String getBrokerName() 
 public Set<ActiveMQDestination> getDestinations() 
 public File getDirectory() 
 public long getLastMessageBrokerSequenceId() throws IOException 
 protected ListContainer<TopicSubAck> getListContainer(Object id,
    String containerName) throws IOException 
 protected MapContainer<MessageId, Message> getMapContainer(Object id,
    String containerName) throws IOException 
 public long getMaxDataFileLength() 
 protected final synchronized Store getStore() throws IOException 
 protected MapContainer getSubsMapContainer(Object id,
    String containerName) throws IOException 
 public boolean isPersistentIndex() 
 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
 protected MessageStore retrieveMessageStore(Object id) 
 public  void rollbackTransaction(ConnectionContext context) 
 public  void setBrokerName(String brokerName) 
 public  void setBrokerService(BrokerService brokerService) 
 public  void setDirectory(File directory) 
 public  void setMaxDataFileLength(long maxDataFileLength) 
    When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
 public  void setPersistentIndex(boolean persistentIndex) 
 public  void setUsageManager(SystemUsage usageManager) 
 public long size() 
 public  void start() throws Exception 
 public  void stop() throws Exception 
 public String toString()