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

All Implemented Interfaces:
    PendingMessageCursor

persist pending messages pending message (messages awaiting dispatch to a consumer) cursor
Fields inherited from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor:
memoryUsageHighWaterMark,  maxBatchSize,  systemUsage,  maxProducersToAudit,  maxAuditDepth,  enableAudit,  audit,  useCache,  last
Constructor:
 public StoreDurableSubscriberCursor(Broker broker,
    String clientId,
    String subscriberName,
    int maxBatchSize,
    Subscription subscription) 
    Parameters:
    broker - Broker for this cursor
    clientId - clientId for this cursor
    subscriberName - subscriber name for this cursor
    maxBatchSize - currently ignored
    subscription - subscription for this cursor
Method from org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor Summary:
add,   addMessageLast,   addRecoveredMessage,   clear,   gc,   getNextCursor,   hasNext,   isEmpty,   isEmpty,   isRecoveryRequired,   next,   release,   remove,   remove,   remove,   reset,   setEnableAudit,   setMaxAuditDepth,   setMaxBatchSize,   setMaxProducersToAudit,   setMemoryUsageHighWaterMark,   setSystemUsage,   setUseCache,   size,   start,   stop,   toString
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.StoreDurableSubscriberCursor Detail:
 public synchronized  void add(ConnectionContext context,
    Destination destination) throws Exception 
    Add a destination
 public synchronized  void addMessageLast(MessageReference node) throws Exception 
 public synchronized  void addRecoveredMessage(MessageReference node) throws Exception 
 public synchronized  void clear() 
 public synchronized  void gc() 
 protected synchronized PendingMessageCursor getNextCursor() throws Exception 
 public synchronized boolean hasNext() 
 public synchronized boolean isEmpty() 
 public synchronized boolean isEmpty(Destination destination) 
 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 synchronized  void release() 
 public synchronized  void remove() 
 public synchronized  void remove(MessageReference node) 
 public synchronized List<MessageReference> remove(ConnectionContext context,
    Destination destination) throws Exception 
    remove a destination
 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 setSystemUsage(SystemUsage usageManager) 
 public  void setUseCache(boolean useCache) 
 public synchronized int size() 
 public synchronized  void start() throws Exception 
 public synchronized  void stop() throws Exception 
 public String toString()