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

All Implemented Interfaces:
    TopicMessageStore, MessageStore

Field Summary
protected  ListContainer<TopicSubAck> ackContainer     
protected  Map<Object, TopicSubContainer> subscriberMessages     
Fields inherited from org.apache.activemq.store.kahadaptor.KahaMessageStore:
messageContainer,  batchEntry
Fields inherited from org.apache.activemq.store.AbstractMessageStore:
destination
Constructor:
 public KahaTopicMessageStore(Store store,
    MapContainer<MessageId, Message> messageContainer,
    ListContainer<TopicSubAck> ackContainer,
    MapContainer<String, SubscriptionInfo> subsContainer,
    ActiveMQDestination destination) throws IOException 
Method from org.apache.activemq.store.kahadaptor.KahaTopicMessageStore Summary:
acknowledge,   addMessage,   addSubsciption,   addSubscriberMessageContainer,   delete,   deleteSubscription,   getAllSubscriptions,   getMessageCount,   getSubscriptionKey,   lookupSubscription,   recoverNextMessages,   recoverSubscription,   removeAllMessages,   removeSubscriberMessageContainer,   resetBatching
Methods from org.apache.activemq.store.kahadaptor.KahaMessageStore:
addMessage,   delete,   getId,   getMessage,   getMessageCount,   getMessageId,   getPreviousMessageIdToDeliver,   isSupportForCursors,   recover,   recoverMessage,   recoverNextMessages,   removeAllMessages,   removeMessage,   removeMessage,   resetBatching,   setBatch
Methods from org.apache.activemq.store.AbstractMessageStore:
dispose,   getDestination,   isEmpty,   setBatch,   setMemoryUsage,   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.KahaTopicMessageStore Detail:
 public synchronized  void acknowledge(ConnectionContext context,
    String clientId,
    String subscriptionName,
    MessageId messageId) throws IOException 
 public synchronized  void addMessage(ConnectionContext context,
    Message message) throws IOException 
 public synchronized  void addSubsciption(SubscriptionInfo info,
    boolean retroactive) throws IOException 
 protected MapContainer addSubscriberMessageContainer(Object key) throws IOException 
 public synchronized  void delete() 
 public synchronized  void deleteSubscription(String clientId,
    String subscriptionName) throws IOException 
 public SubscriptionInfo[] getAllSubscriptions() throws IOException 
 public synchronized int getMessageCount(String clientId,
    String subscriberName) throws IOException 
 protected String getSubscriptionKey(String clientId,
    String subscriberName) 
 public synchronized SubscriptionInfo lookupSubscription(String clientId,
    String subscriptionName) throws IOException 
 public synchronized  void recoverNextMessages(String clientId,
    String subscriptionName,
    int maxReturned,
    MessageRecoveryListener listener) throws Exception 
 public synchronized  void recoverSubscription(String clientId,
    String subscriptionName,
    MessageRecoveryListener listener) throws Exception 
 public synchronized  void removeAllMessages(ConnectionContext context) throws IOException 
 protected synchronized  void removeSubscriberMessageContainer(Object key) throws IOException 
 public synchronized  void resetBatching(String clientId,
    String subscriptionName)