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

All Implemented Interfaces:
    PendingMessageCursor

Direct Known Subclasses:
    FilePendingMessageCursor, QueueStorePrefetch, AbstractStoreCursor, StoreQueueCursor, TopicStorePrefetch, VMPendingMessageCursor, StoreDurableSubscriberCursor

Abstract method holder for pending message (messages awaiting disptach to a consumer) cursor
Field Summary
protected  int memoryUsageHighWaterMark     
protected  int maxBatchSize     
protected  SystemUsage systemUsage     
protected  int maxProducersToAudit     
protected  int maxAuditDepth     
protected  boolean enableAudit     
protected  ActiveMQMessageAudit audit     
protected  boolean useCache     
protected  MessageReference last     
Method from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor Summary:
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.AbstractPendingMessageCursor Detail:
 public  void add(ConnectionContext context,
    Destination destination) throws Exception 
 public  void addMessageFirst(MessageReference node) throws Exception 
 public  void addMessageLast(MessageReference node) throws Exception 
 public  void addRecoveredMessage(MessageReference node) throws Exception 
 public  void clear() 
 public  void destroy() throws Exception 
    destroy the cursor
 protected  void fillBatch() throws Exception 
 public  void gc() 
 public int getMaxAuditDepth() 
 public int getMaxBatchSize() 
 public int getMaxProducersToAudit() 
 public int getMemoryUsageHighWaterMark() 
 public ActiveMQMessageAudit getMessageAudit() 
 public SystemUsage getSystemUsage() 
 public boolean hasMessagesBufferedToDeliver() 
 public boolean hasNext() 
 public boolean hasSpace() 
 public synchronized boolean isDuplicate(MessageId messageId) 
 public boolean isEmpty() 
 public boolean isEmpty(Destination destination) 
 public boolean isEnableAudit() 
 public boolean isFull() 
 public boolean isRecoveryRequired() 
 protected synchronized boolean isStarted() 
 public boolean isTransient() 
 public boolean isUseCache() 
 public MessageReference next() 
 public LinkedList<MessageReference> pageInList(int maxItems) 
    Page in a restricted number of messages
 public synchronized boolean recordUniqueId(MessageId messageId) 
    records a message id and checks if it is a duplicate
 public  void release() 
 public  void remove() 
 public  void remove(MessageReference node) 
 public List<MessageReference> remove(ConnectionContext context,
    Destination destination) throws Exception 
 public  void reset() 
 public  void resetForGC() 
 public synchronized  void rollback(MessageId id) 
 public synchronized  void setEnableAudit(boolean enableAudit) 
 public synchronized  void setMaxAuditDepth(int maxAuditDepth) 
 public  void setMaxBatchSize(int maxBatchSize) 
 public synchronized  void setMaxProducersToAudit(int maxProducersToAudit) 
 public  void setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark) 
 public  void setMessageAudit(ActiveMQMessageAudit audit) 
    set the audit
 public  void setSystemUsage(SystemUsage usageManager) 
 public  void setUseCache(boolean useCache) 
 public int size() 
 public synchronized  void start() throws Exception 
 public synchronized  void stop() throws Exception