Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » cursors » [javadoc | source]
org.apache.activemq.broker.region.cursors
class: TopicStorePrefetch [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.TopicStorePrefetch

All Implemented Interfaces:
    MessageRecoveryListener, PendingMessageCursor

perist pendingCount messages pendingCount message (messages awaiting disptach 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 TopicStorePrefetch(Subscription subscription,
    Topic topic,
    String clientId,
    String subscriberName) 
    Parameters:
    topic -
    clientId -
    subscriberName -
Method from org.apache.activemq.broker.region.cursors.TopicStorePrefetch Summary:
doFillBatch,   getStoreSize,   isStoreEmpty,   recoverMessage,   recoverMessageReference,   resetBatch,   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.TopicStorePrefetch Detail:
 protected  void doFillBatch() throws Exception 
 protected synchronized int getStoreSize() 
 protected synchronized boolean isStoreEmpty() 
 public synchronized boolean recoverMessage(Message message,
    boolean cached) throws Exception 
 public boolean recoverMessageReference(MessageId messageReference) throws Exception 
 protected  void resetBatch() 
 public String toString()