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

All Implemented Interfaces:
    MessageRecoveryListener, PendingMessageCursor

persist pending messages pending message (messages awaiting dispatch to a consumer) cursor
Fields inherited from org.apache.activemq.broker.region.cursors.AbstractStoreCursor:
regionDestination,  batchResetNeeded,  storeHasMessages,  size
Fields inherited from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor:
memoryUsageHighWaterMark,  maxBatchSize,  systemUsage,  maxProducersToAudit,  maxAuditDepth,  enableAudit,  audit,  useCache,  last
Constructor:
 public QueueStorePrefetch(Queue queue) 
    Construct it
    Parameters:
    queue -
Method from org.apache.activemq.broker.region.cursors.QueueStorePrefetch Summary:
doFillBatch,   getStoreSize,   isStoreEmpty,   recoverMessageReference,   resetBatch,   setBatch,   toString
Methods from org.apache.activemq.broker.region.cursors.AbstractStoreCursor:
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.QueueStorePrefetch Detail:
 protected  void doFillBatch() throws Exception 
 protected synchronized int getStoreSize() 
 protected synchronized boolean isStoreEmpty() 
 public boolean recoverMessageReference(MessageId messageReference) throws Exception 
 protected  void resetBatch() 
 protected  void setBatch(MessageId messageId) throws Exception 
 public String toString()