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

All Implemented Interfaces:
    PendingMessageCursor

hold pending messages in a linked list (messages awaiting disptach 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 VMPendingMessageCursor() 
Method from org.apache.activemq.broker.region.cursors.VMPendingMessageCursor Summary:
addMessageFirst,   addMessageLast,   clear,   destroy,   hasNext,   isEmpty,   isTransient,   next,   pageInList,   remove,   remove,   remove,   reset,   size
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.VMPendingMessageCursor Detail:
 public synchronized  void addMessageFirst(MessageReference node) 
    add message to await dispatch
 public synchronized  void addMessageLast(MessageReference node) 
    add message to await dispatch
 public synchronized  void clear() 
    clear all pending messages
 public  void destroy() throws Exception 
 public synchronized boolean hasNext() 
 public synchronized boolean isEmpty() 
 public boolean isTransient() 
 public synchronized MessageReference next() 
 public LinkedList<MessageReference> pageInList(int maxItems) 
    Page in a restricted number of messages
 public synchronized  void remove() 
    remove the message at the cursor position
 public synchronized  void remove(MessageReference node) 
 public synchronized List<MessageReference> remove(ConnectionContext context,
    Destination destination) throws Exception 
 public synchronized  void reset() 
    reset the cursor
 public synchronized int size()