|
||||||||||
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 |
---|
audit, enableAudit, last, maxAuditDepth, maxBatchSize, maxProducersToAudit, memoryUsageHighWaterMark, prioritizedMessages, systemUsage, useCache |
Constructor Summary | |
---|---|
VMPendingMessageCursor(boolean prioritizedMessages)
|
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 |
void |
destroy()
destroy the cursor |
boolean |
hasNext()
|
boolean |
isEmpty()
|
boolean |
isTransient()
|
MessageReference |
next()
|
java.util.LinkedList<MessageReference> |
pageInList(int maxItems)
Page in a restricted number of messages |
void |
remove()
remove the message at the cursor position |
java.util.List<MessageReference> |
remove(ConnectionContext context,
Destination destination)
remove a destination |
void |
remove(MessageReference node)
remove a node |
void |
reset()
reset the cursor |
int |
size()
|
Methods inherited from class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor |
---|
add, addRecoveredMessage, fillBatch, gc, getMaxAuditDepth, getMaxBatchSize, getMaxProducersToAudit, getMemoryUsageHighWaterMark, getMessageAudit, getSystemUsage, hasMessagesBufferedToDeliver, hasSpace, isCacheEnabled, isDuplicate, isEmpty, isEnableAudit, isFull, isPrioritizedMessageSubscriber, isRecoveryRequired, isStarted, isUseCache, recordUniqueId, release, resetForGC, rollback, setCacheEnabled, setEnableAudit, setMaxAuditDepth, setMaxBatchSize, setMaxProducersToAudit, setMemoryUsageHighWaterMark, setMessageAudit, setSystemUsage, setUseCache, start, stop, tryAddMessageLast |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public VMPendingMessageCursor(boolean prioritizedMessages)
Method Detail |
---|
public java.util.List<MessageReference> remove(ConnectionContext context, Destination destination) throws java.lang.Exception
PendingMessageCursor
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
java.lang.Exception
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
public void remove(MessageReference node)
PendingMessageCursor
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
public java.util.LinkedList<MessageReference> pageInList(int maxItems)
pageInList
in interface PendingMessageCursor
pageInList
in class AbstractPendingMessageCursor
maxItems
-
public boolean isTransient()
isTransient
in interface PendingMessageCursor
isTransient
in class AbstractPendingMessageCursor
public void destroy() throws java.lang.Exception
AbstractPendingMessageCursor
destroy
in interface PendingMessageCursor
destroy
in class AbstractPendingMessageCursor
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |