public interface QueueViewMBean extends DestinationViewMBean
Modifier and Type | Method and Description |
---|---|
int |
copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Copies the messages matching the given selector
|
int |
copyMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Copies the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
copyMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Copies a given message to another destination.
|
int |
cursorSize() |
boolean |
doesCursorHaveMessagesBuffered() |
boolean |
doesCursorHaveSpace() |
long |
getCursorMemoryUsage() |
int |
getCursorPercentUsage() |
javax.management.openmbean.CompositeData |
getMessage(java.lang.String messageId)
Retrieve a message from the destination's queue.
|
boolean |
isCacheEnabled() |
boolean |
isCursorFull() |
int |
moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName)
Moves the messages matching the given selector
|
int |
moveMatchingMessagesTo(java.lang.String selector,
java.lang.String destinationName,
int maximumMessages)
Moves the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
moveMessageTo(java.lang.String messageId,
java.lang.String destinationName)
Moves the message to another destination.
|
void |
purge()
Removes all of the messages in the queue.
|
int |
removeMatchingMessages(java.lang.String selector)
Removes the messages matching the given selector
|
int |
removeMatchingMessages(java.lang.String selector,
int maximumMessages)
Removes the messages matching the given selector up to the maximum number
of matched messages
|
boolean |
removeMessage(java.lang.String messageId)
Removes a message from the queue.
|
boolean |
retryMessage(java.lang.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, isPrioritizedMessages, isProducerFlowControl, isUseCache, resetStatistics, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessage, setBlockedProducerWarningInterval, setMaxAuditDepth, setMaxPageSize, setMaxProducersToAudit, setMemoryLimit, setMemoryUsagePortion, setProducerFlowControl, setUseCache
javax.management.openmbean.CompositeData getMessage(java.lang.String messageId) throws javax.management.openmbean.OpenDataException
messageId
- the message id of the message to retrievejavax.management.openmbean.OpenDataException
boolean removeMessage(java.lang.String messageId) throws java.lang.Exception
messageId
- java.lang.Exception
int removeMatchingMessages(java.lang.String selector) throws java.lang.Exception
java.lang.Exception
int removeMatchingMessages(java.lang.String selector, int maximumMessages) throws java.lang.Exception
java.lang.Exception
void purge() throws java.lang.Exception
java.lang.Exception
boolean copyMessageTo(java.lang.String messageId, java.lang.String destinationName) throws java.lang.Exception
messageId
- destinationName
- java.lang.Exception
int copyMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName) throws java.lang.Exception
java.lang.Exception
int copyMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName, int maximumMessages) throws java.lang.Exception
java.lang.Exception
boolean moveMessageTo(java.lang.String messageId, java.lang.String destinationName) throws java.lang.Exception
messageId
- destinationName
- java.lang.Exception
boolean retryMessage(java.lang.String messageId) throws java.lang.Exception
java.lang.Exception
int moveMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName) throws java.lang.Exception
java.lang.Exception
int moveMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName, int maximumMessages) throws java.lang.Exception
java.lang.Exception
boolean doesCursorHaveSpace()
boolean isCursorFull()
boolean doesCursorHaveMessagesBuffered()
long getCursorMemoryUsage()
int getCursorPercentUsage()
int cursorSize()
boolean isCacheEnabled()
Copyright © 2005-2012. All Rights Reserved.