Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » cursors » [javadoc | source]
org.apache.activemq.broker.region.cursors
abstract public class: AbstractStoreCursor [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
      org.apache.activemq.broker.region.cursors.AbstractStoreCursor

All Implemented Interfaces:
    MessageRecoveryListener, PendingMessageCursor

Direct Known Subclasses:
    QueueStorePrefetch, TopicStorePrefetch

Store based cursor
Field Summary
protected final  Destination regionDestination     
protected  boolean batchResetNeeded     
protected  boolean storeHasMessages     
protected  int size     
Fields inherited from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor:
memoryUsageHighWaterMark,  maxBatchSize,  systemUsage,  maxProducersToAudit,  maxAuditDepth,  enableAudit,  audit,  useCache,  last
Constructor:
 protected AbstractStoreCursor(Destination destination) 
Method from org.apache.activemq.broker.region.cursors.AbstractStoreCursor Summary:
addMessageFirst,   addMessageLast,   clear,   doFillBatch,   fillBatch,   finished,   gc,   getStoreSize,   hasMessagesBufferedToDeliver,   hasNext,   isEmpty,   isStoreEmpty,   next,   recoverMessage,   recoverMessage,   release,   remove,   remove,   reset,   resetBatch,   setBatch,   size,   start,   stop
Methods from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor:
add,   addMessageFirst,   addMessageLast,   addRecoveredMessage,   clear,   destroy,   fillBatch,   gc,   getMaxAuditDepth,   getMaxBatchSize,   getMaxProducersToAudit,   getMemoryUsageHighWaterMark,   getMessageAudit,   getSystemUsage,   hasMessagesBufferedToDeliver,   hasNext,   hasSpace,   isDuplicate,   isEmpty,   isEmpty,   isEnableAudit,   isFull,   isRecoveryRequired,   isStarted,   isTransient,   isUseCache,   next,   pageInList,   recordUniqueId,   release,   remove,   remove,   remove,   reset,   resetForGC,   rollback,   setEnableAudit,   setMaxAuditDepth,   setMaxBatchSize,   setMaxProducersToAudit,   setMemoryUsageHighWaterMark,   setMessageAudit,   setSystemUsage,   setUseCache,   size,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.cursors.AbstractStoreCursor Detail:
 public final synchronized  void addMessageFirst(MessageReference node) throws Exception 
 public final synchronized  void addMessageLast(MessageReference node) throws Exception 
 public final synchronized  void clear() 
 abstract protected  void doFillBatch() throws Exception
 protected final synchronized  void fillBatch() 
 public final  void finished() 
 public final synchronized  void gc() 
 abstract protected int getStoreSize()
 public final synchronized boolean hasMessagesBufferedToDeliver() 
 public final synchronized boolean hasNext() 
 public final synchronized boolean isEmpty() 
 abstract protected boolean isStoreEmpty()
 public final synchronized MessageReference next() 
 public final boolean recoverMessage(Message message) throws Exception 
 public synchronized boolean recoverMessage(Message message,
    boolean cached) throws Exception 
 public synchronized  void release() 
 public final synchronized  void remove() 
 public final synchronized  void remove(MessageReference node) 
 public final  void reset() 
 abstract protected  void resetBatch()
 protected  void setBatch(MessageId messageId) throws Exception 
 public final synchronized int size() 
 public final synchronized  void start() throws Exception 
 public final synchronized  void stop() throws Exception