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

All Implemented Interfaces:
    MessageStore

Direct Known Subclasses:
    KahaTopicMessageStore

An implementation of org.apache.activemq.store.MessageStore which uses a JPS Container
Field Summary
protected final  MapContainer<MessageId, Message> messageContainer     
protected  StoreEntry batchEntry     
Fields inherited from org.apache.activemq.store.AbstractMessageStore:
destination
Constructor:
 public KahaMessageStore(MapContainer<MessageId, Message> container,
    ActiveMQDestination destination) throws IOException 
Method from org.apache.activemq.store.kahadaptor.KahaMessageStore Summary:
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.KahaMessageStore Detail:
 public synchronized  void addMessage(ConnectionContext context,
    Message message) throws IOException 
 public synchronized  void delete() 
 public Object getId() 
 public synchronized Message getMessage(MessageId identity) throws IOException 
 public int getMessageCount() 
 protected MessageId getMessageId(Object object) 
 public MessageId getPreviousMessageIdToDeliver(MessageId id) throws Exception 
 public boolean isSupportForCursors() 
 public synchronized  void recover(MessageRecoveryListener listener) throws Exception 
 protected boolean recoverMessage(MessageRecoveryListener listener,
    Message msg) throws Exception 
 public synchronized  void recoverNextMessages(int maxReturned,
    MessageRecoveryListener listener) throws Exception 
 public synchronized  void removeAllMessages(ConnectionContext context) throws IOException 
 public synchronized  void removeMessage(MessageId msgId) throws IOException 
 public  void removeMessage(ConnectionContext context,
    MessageAck ack) throws IOException 
 public synchronized  void resetBatching() 
 public  void setBatch(MessageId messageId)