|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
org.apache.activemq.broker.region.cursors.VMPendingMessageCursor
public class VMPendingMessageCursor
hold pending messages in a linked list (messages awaiting disptach to a consumer) cursor
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 |
---|
public VMPendingMessageCursor()
Method Detail |
---|
public boolean isEmpty()
isEmpty
in interface PendingMessageCursor
isEmpty
in class AbstractPendingMessageCursor
public void reset()
reset
in interface PendingMessageCursor
reset
in class AbstractPendingMessageCursor
public void addMessageLast(MessageReference node)
addMessageLast
in interface PendingMessageCursor
addMessageLast
in class AbstractPendingMessageCursor
node
- public void addMessageFirst(MessageReference node)
addMessageFirst
in interface PendingMessageCursor
addMessageFirst
in class AbstractPendingMessageCursor
position
- node
- public boolean hasNext()
hasNext
in interface PendingMessageCursor
hasNext
in class AbstractPendingMessageCursor
public MessageReference next()
next
in interface PendingMessageCursor
next
in class AbstractPendingMessageCursor
public void remove()
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
public int size()
size
in interface PendingMessageCursor
size
in class AbstractPendingMessageCursor
public void clear()
clear
in interface PendingMessageCursor
clear
in class AbstractPendingMessageCursor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |