public interface QueueViewMBean extends DestinationViewMBean
Modifier and Type | Method and Description |
---|---|
int |
copyMatchingMessagesTo(String selector,
String destinationName)
Copies the messages matching the given selector
|
int |
copyMatchingMessagesTo(String selector,
String destinationName,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
copyMessageTo(String messageId,
String destinationName)
Copies a given message to another destination.
|
int |
cursorSize() |
boolean |
doesCursorHaveMessagesBuffered() |
boolean |
doesCursorHaveSpace() |
long |
getCursorMemoryUsage() |
int |
getCursorPercentUsage() |
CompositeData |
getMessage(String messageId)
Retrieve a message from the destination's queue.
|
boolean |
isCacheEnabled() |
boolean |
isCursorFull() |
int |
moveMatchingMessagesTo(String selector,
String destinationName)
Moves the messages matching the given selector
|
int |
moveMatchingMessagesTo(String selector,
String destinationName,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
moveMessageTo(String messageId,
String destinationName)
Moves the message to another destination.
|
void |
purge()
Removes all of the messages in the queue.
|
int |
removeMatchingMessages(String selector)
Removes the messages matching the given selector
|
int |
removeMatchingMessages(String selector,
int maximumMessages)
Removes the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
removeMessage(String messageId)
Removes a message from the queue.
|
boolean |
retryMessage(String messageId)
Moves a message back to its original destination
|
browse, browse, browseAsTable, browseAsTable, browseMessages, browseMessages, getAverageEnqueueTime, getBlockedProducerWarningInterval, getConsumerCount, getDequeueCount, getDispatchCount, getEnqueueCount, getExpiredCount, getInFlightCount, getMaxAuditDepth, getMaxEnqueueTime, getMaxPageSize, getMaxProducersToAudit, getMemoryLimit, getMemoryPercentUsage, getMemoryUsagePortion, getMinEnqueueTime, getName, getProducerCount, getQueueSize, getSlowConsumerStrategy, getSubscriptions, isAlwaysRetroactive, isPrioritizedMessages, isProducerFlowControl, isUseCache, resetStatistics, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessage, setAlwaysRetroactive, setBlockedProducerWarningInterval, setMaxAuditDepth, setMaxPageSize, setMaxProducersToAudit, setMemoryLimit, setMemoryUsagePortion, setProducerFlowControl, setUseCache
CompositeData getMessage(String messageId) throws OpenDataException
messageId
- the message id of the message to retrieveOpenDataException
boolean removeMessage(String messageId) throws Exception
messageId
- Exception
int removeMatchingMessages(String selector) throws Exception
Exception
int removeMatchingMessages(String selector, int maximumMessages) throws Exception
Exception
boolean copyMessageTo(String messageId, String destinationName) throws Exception
messageId
- destinationName
- Exception
int copyMatchingMessagesTo(String selector, String destinationName) throws Exception
Exception
int copyMatchingMessagesTo(String selector, String destinationName, int maximumMessages) throws Exception
Exception
boolean moveMessageTo(String messageId, String destinationName) throws Exception
messageId
- destinationName
- Exception
boolean retryMessage(String messageId) throws Exception
Exception
int moveMatchingMessagesTo(String selector, String destinationName) throws Exception
Exception
int moveMatchingMessagesTo(String selector, String destinationName, int maximumMessages) throws Exception
Exception
boolean doesCursorHaveSpace()
boolean isCursorFull()
boolean doesCursorHaveMessagesBuffered()
long getCursorMemoryUsage()
int getCursorPercentUsage()
int cursorSize()
boolean isCacheEnabled()
Copyright © 2005–2016. All rights reserved.