public class VMPendingMessageCursor extends AbstractPendingMessageCursor
audit, enableAudit, last, maxAuditDepth, maxBatchSize, maxProducersToAudit, memoryUsageHighWaterMark, prioritizedMessages, systemUsage, useCache
INFINITE_WAIT
Constructor and Description |
---|
VMPendingMessageCursor(boolean prioritizedMessages) |
Modifier and Type | Method and Description |
---|---|
void |
addMessageFirst(MessageReference node)
add message to await dispatch
|
void |
clear()
clear all pending messages
|
void |
destroy()
destroy the cursor
|
boolean |
hasNext() |
boolean |
isEmpty() |
boolean |
isTransient() |
long |
messageSize() |
MessageReference |
next() |
LinkedList<MessageReference> |
pageInList(int maxItems)
Page in a restricted number of messages
|
void |
remove()
remove the message at the cursor position
|
List<MessageReference> |
remove(ConnectionContext context,
Destination destination)
remove a destination
|
void |
remove(MessageReference node)
remove a node
|
void |
reset()
reset the cursor
|
int |
size() |
boolean |
tryAddMessageLast(MessageReference node,
long maxWait)
add message to await dispatch
|
add, addMessageLast, addRecoveredMessage, fillBatch, gc, getMaxAuditDepth, getMaxBatchSize, getMaxProducersToAudit, getMemoryUsageHighWaterMark, getMessageAudit, getSystemUsage, hasMessagesBufferedToDeliver, hasSpace, isCacheEnabled, isDuplicate, isEmpty, isEnableAudit, isFull, isPrioritizedMessageSubscriber, isRecoveryRequired, isStarted, isUseCache, rebase, recordUniqueId, release, resetForGC, rollback, setCacheEnabled, setEnableAudit, setMaxAuditDepth, setMaxBatchSize, setMaxProducersToAudit, setMemoryUsageHighWaterMark, setMessageAudit, setSystemUsage, setUseCache, start, stop
public VMPendingMessageCursor(boolean prioritizedMessages)
public List<MessageReference> remove(ConnectionContext context, Destination destination) throws Exception
PendingMessageCursor
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
Exception
public boolean isEmpty()
isEmpty
in interface PendingMessageCursor
isEmpty
in class AbstractPendingMessageCursor
public void reset()
reset
in interface PendingMessageCursor
reset
in class AbstractPendingMessageCursor
public boolean tryAddMessageLast(MessageReference node, long maxWait)
tryAddMessageLast
in interface PendingMessageCursor
tryAddMessageLast
in class AbstractPendingMessageCursor
node
- public void addMessageFirst(MessageReference node)
addMessageFirst
in interface PendingMessageCursor
addMessageFirst
in class AbstractPendingMessageCursor
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 long messageSize()
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 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 Exception
AbstractPendingMessageCursor
destroy
in interface PendingMessageCursor
destroy
in class AbstractPendingMessageCursor
Exception
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.