org.apache.activemq.broker.region.cursors
Class FilePendingMessageCursor

java.lang.Object
  extended by org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
      extended by org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
All Implemented Interfaces:
PendingMessageCursor, Service

public class FilePendingMessageCursor
extends AbstractPendingMessageCursor

perist pending messages pending message (messages awaiting disptach to a consumer) cursor

Version:
$Revision: 474986 $

Field Summary
 
Fields inherited from class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
maxBatchSize
 
Constructor Summary
FilePendingMessageCursor(java.lang.String name, Store store)
           
 
Method Summary
 void addMessageFirst(MessageReference node)
          add message to await dispatch
 void addMessageLast(MessageReference node)
          add message to await dispatch
 void clear()
          clear all pending messages
 boolean hasNext()
           
 boolean isEmpty()
           
 MessageReference next()
           
 void remove()
          remove the message at the cursor position
 void reset()
          reset the cursor
 int size()
           
 
Methods inherited from class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
add, fillBatch, getMaxBatchSize, isRecoveryRequired, remove, resetForGC, setMaxBatchSize, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FilePendingMessageCursor

public FilePendingMessageCursor(java.lang.String name,
                                Store store)
Parameters:
name -
store -
Throws:
java.io.IOException
Method Detail

isEmpty

public boolean isEmpty()
Specified by:
isEmpty in interface PendingMessageCursor
Overrides:
isEmpty in class AbstractPendingMessageCursor
Returns:
true if there are no pending messages

reset

public void reset()
reset the cursor

Specified by:
reset in interface PendingMessageCursor
Overrides:
reset in class AbstractPendingMessageCursor

addMessageLast

public void addMessageLast(MessageReference node)
add message to await dispatch

Specified by:
addMessageLast in interface PendingMessageCursor
Overrides:
addMessageLast in class AbstractPendingMessageCursor
Parameters:
node -

addMessageFirst

public void addMessageFirst(MessageReference node)
add message to await dispatch

Specified by:
addMessageFirst in interface PendingMessageCursor
Overrides:
addMessageFirst in class AbstractPendingMessageCursor
Parameters:
position -
node -

hasNext

public boolean hasNext()
Specified by:
hasNext in interface PendingMessageCursor
Overrides:
hasNext in class AbstractPendingMessageCursor
Returns:
true if there pending messages to dispatch

next

public MessageReference next()
Specified by:
next in interface PendingMessageCursor
Overrides:
next in class AbstractPendingMessageCursor
Returns:
the next pending message

remove

public void remove()
remove the message at the cursor position

Specified by:
remove in interface PendingMessageCursor
Overrides:
remove in class AbstractPendingMessageCursor

size

public int size()
Specified by:
size in interface PendingMessageCursor
Overrides:
size in class AbstractPendingMessageCursor
Returns:
the number of pending messages

clear

public void clear()
clear all pending messages

Specified by:
clear in interface PendingMessageCursor
Overrides:
clear in class AbstractPendingMessageCursor


Copyright © 2009 Apache Software Foundation. All Rights Reserved.