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

All Implemented Interfaces:
    UsageListener, PendingMessageCursor

persist pending messages pending message (messages awaiting dispatch to a consumer) cursor
Field Summary
protected  Broker broker     
Fields inherited from org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor:
memoryUsageHighWaterMark,  maxBatchSize,  systemUsage,  maxProducersToAudit,  maxAuditDepth,  enableAudit,  audit,  useCache,  last
Constructor:
 public FilePendingMessageCursor(Broker broker,
    String name) 
    Parameters:
    name -
    store -
Method from org.apache.activemq.broker.region.cursors.FilePendingMessageCursor Summary:
addMessageFirst,   addMessageLast,   clear,   destroy,   discard,   expireOldMessages,   flushToDisk,   getDiskList,   hasMessagesBufferedToDeliver,   hasNext,   isDiskListEmpty,   isEmpty,   isFull,   isSpaceInMemoryList,   isTransient,   next,   onUsageChanged,   pageInList,   release,   remove,   remove,   reset,   setSystemUsage,   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.FilePendingMessageCursor 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 synchronized  void destroy() throws Exception 
 protected  void discard(MessageReference message) 
 protected synchronized  void expireOldMessages() 
 protected synchronized  void flushToDisk() 
 protected ListContainer<MessageReference> getDiskList() 
 public boolean hasMessagesBufferedToDeliver() 
 public synchronized boolean hasNext() 
 protected boolean isDiskListEmpty() 
 public synchronized boolean isEmpty() 
 public synchronized boolean isFull() 
 protected boolean isSpaceInMemoryList() 
 public boolean isTransient() 
 public synchronized MessageReference next() 
 public  void onUsageChanged(Usage usage,
    int oldPercentUsage,
    int newPercentUsage) 
 public synchronized LinkedList<MessageReference> pageInList(int maxItems) 
 public synchronized  void release() 
 public synchronized  void remove() 
    remove the message at the cursor position
 public synchronized  void remove(MessageReference node) 
 public synchronized  void reset() 
    reset the cursor
 public  void setSystemUsage(SystemUsage usageManager) 
 public synchronized int size() 
 public  void start() throws Exception 
 public  void stop() throws Exception