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.
|
Map<String,String> |
getMessageGroups() |
String |
getMessageGroupType() |
boolean |
isCacheEnabled() |
boolean |
isCursorFull() |
boolean |
isPaused() |
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 |
pause() |
void |
purge()
Removes all of the messages in the queue.
|
void |
removeAllMessageGroups()
remove all the message groups - will rebalance all message groups across consumers
|
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.
|
void |
removeMessageGroup(String groupName)
remove a message group = has the effect of rebalancing group
|
void |
resume() |
boolean |
retryMessage(String messageId)
Moves a message back to its original destination
|
int |
retryMessages()
Retries messages sent to the DLQ
|
browse, browse, browseAsTable, browseAsTable, browseMessages, browseMessages, getAverageBlockedTime, getAverageEnqueueTime, getAverageMessageSize, getBlockedProducerWarningInterval, getBlockedSends, getConsumerCount, getDequeueCount, getDispatchCount, getEnqueueCount, getExpiredCount, getForwardCount, getInFlightCount, getMaxAuditDepth, getMaxEnqueueTime, getMaxMessageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryLimit, getMemoryPercentUsage, getMemoryUsageByteCount, getMemoryUsagePortion, getMinEnqueueTime, getMinMessageSize, getName, getOptions, getProducerCount, getQueueSize, getSlowConsumerStrategy, getStoreMessageSize, getSubscriptions, getTotalBlockedTime, isAlwaysRetroactive, isDLQ, isPrioritizedMessages, isProducerFlowControl, isUseCache, resetStatistics, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessageWithProperties, 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
int retryMessages() throws Exception
Exception
boolean doesCursorHaveSpace()
boolean isCursorFull()
boolean doesCursorHaveMessagesBuffered()
long getCursorMemoryUsage()
int getCursorPercentUsage()
int cursorSize()
boolean isCacheEnabled()
Map<String,String> getMessageGroups()
String getMessageGroupType()
void removeMessageGroup(String groupName)
groupName
- void removeAllMessageGroups()
void pause()
void resume()
boolean isPaused()
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.