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

All Implemented Interfaces:
    PendingMessageCursor

Store based Cursor for Queues
Fields inherited from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor:
memoryUsageHighWaterMark,  maxBatchSize,  systemUsage,  maxProducersToAudit,  maxAuditDepth,  enableAudit,  audit,  useCache,  last
Constructor:
 public StoreQueueCursor(Broker broker,
    Queue queue) 
    Construct
    Parameters:
    queue -
    tmpStore -
Method from org.apache.activemq.broker.region.cursors.StoreQueueCursor Summary:
addMessageFirst,   addMessageLast,   clear,   gc,   getNextCursor,   getNonPersistent,   hasNext,   isEmpty,   isRecoveryRequired,   next,   release,   remove,   remove,   reset,   setEnableAudit,   setMaxAuditDepth,   setMaxBatchSize,   setMaxProducersToAudit,   setMemoryUsageHighWaterMark,   setNonPersistent,   setSystemUsage,   setUseCache,   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.StoreQueueCursor Detail:
 public synchronized  void addMessageFirst(MessageReference node) throws Exception 
 public synchronized  void addMessageLast(MessageReference node) throws Exception 
 public synchronized  void clear() 
 public synchronized  void gc() 
 protected synchronized PendingMessageCursor getNextCursor() throws Exception 
 public PendingMessageCursor getNonPersistent() 
 public synchronized boolean hasNext() 
 public synchronized boolean isEmpty() 
 public boolean isRecoveryRequired() 
    Informs the Broker if the subscription needs to intervention to recover it's state e.g. DurableTopicSubscriber may do
 public synchronized MessageReference next() 
 public  void release() 
 public synchronized  void remove() 
 public synchronized  void remove(MessageReference node) 
 public synchronized  void reset() 
 public  void setEnableAudit(boolean enableAudit) 
 public  void setMaxAuditDepth(int maxAuditDepth) 
 public  void setMaxBatchSize(int maxBatchSize) 
 public  void setMaxProducersToAudit(int maxProducersToAudit) 
 public  void setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark) 
 public  void setNonPersistent(PendingMessageCursor nonPersistent) 
 public  void setSystemUsage(SystemUsage usageManager) 
 public  void setUseCache(boolean useCache) 
 public synchronized int size() 
 public synchronized  void start() throws Exception 
 public synchronized  void stop() throws Exception