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

java.lang.Object
  org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
      org.apache.activemq.broker.region.cursors.VMPendingMessageCursor

All Implemented Interfaces:

PendingMessageCursor, Service

public class VMPendingMessageCursor
extends AbstractPendingMessageCursor

hold pending messages in a linked list (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

VMPendingMessageCursor()

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

VMPendingMessageCursor

public VMPendingMessageCursor()

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