public class QueueView extends DestinationView implements QueueViewMBean
broker, destination
Constructor and Description |
---|
QueueView(ManagedRegionBroker broker,
Queue destination) |
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, gc, getAverageBlockedTime, getAverageEnqueueTime, getAverageMessageSize, getBlockedProducerWarningInterval, getBlockedSends, getConsumerCount, getDequeueCount, getDispatchCount, getEnqueueCount, getExpiredCount, getForwardCount, getInFlightCount, getMaxAuditDepth, getMaxEnqueueTime, getMaxMessageSize, getMaxPageSize, getMaxProducersToAudit, getMemoryLimit, getMemoryPercentUsage, getMemoryUsageByteCount, getMemoryUsagePortion, getMessagesCached, getMinEnqueueTime, getMinMessageSize, getName, getOptions, getProducerCount, getQueueSize, getSlowConsumerStrategy, getStoreMessageSize, getSubscriptions, getTotalBlockedTime, isAlwaysRetroactive, isDLQ, isEnableAudit, isPrioritizedMessages, isProducerFlowControl, isUseCache, resetStatistics, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessageWithProperties, setAlwaysRetroactive, setBlockedProducerWarningInterval, setEnableAudit, setMaxAuditDepth, setMaxPageSize, setMaxProducersToAudit, setMemoryLimit, setMemoryUsagePortion, setProducerFlowControl, setUseCache
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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
public QueueView(ManagedRegionBroker broker, Queue destination)
public CompositeData getMessage(String messageId) throws OpenDataException
QueueViewMBean
getMessage
in interface QueueViewMBean
messageId
- the message id of the message to retrieveOpenDataException
public void purge() throws Exception
QueueViewMBean
purge
in interface QueueViewMBean
Exception
public boolean removeMessage(String messageId) throws Exception
QueueViewMBean
removeMessage
in interface QueueViewMBean
Exception
public int removeMatchingMessages(String selector) throws Exception
QueueViewMBean
removeMatchingMessages
in interface QueueViewMBean
Exception
public int removeMatchingMessages(String selector, int maximumMessages) throws Exception
QueueViewMBean
removeMatchingMessages
in interface QueueViewMBean
Exception
public boolean copyMessageTo(String messageId, String destinationName) throws Exception
QueueViewMBean
copyMessageTo
in interface QueueViewMBean
Exception
public int copyMatchingMessagesTo(String selector, String destinationName) throws Exception
QueueViewMBean
copyMatchingMessagesTo
in interface QueueViewMBean
Exception
public int copyMatchingMessagesTo(String selector, String destinationName, int maximumMessages) throws Exception
QueueViewMBean
copyMatchingMessagesTo
in interface QueueViewMBean
Exception
public boolean moveMessageTo(String messageId, String destinationName) throws Exception
QueueViewMBean
moveMessageTo
in interface QueueViewMBean
Exception
public int moveMatchingMessagesTo(String selector, String destinationName) throws Exception
QueueViewMBean
moveMatchingMessagesTo
in interface QueueViewMBean
Exception
public int moveMatchingMessagesTo(String selector, String destinationName, int maximumMessages) throws Exception
QueueViewMBean
moveMatchingMessagesTo
in interface QueueViewMBean
Exception
public int retryMessages() throws Exception
QueueViewMBean
retryMessages
in interface QueueViewMBean
Exception
public boolean retryMessage(String messageId) throws Exception
retryMessage
in interface QueueViewMBean
Exception
public int cursorSize()
cursorSize
in interface QueueViewMBean
public boolean doesCursorHaveMessagesBuffered()
doesCursorHaveMessagesBuffered
in interface QueueViewMBean
public boolean doesCursorHaveSpace()
doesCursorHaveSpace
in interface QueueViewMBean
public long getCursorMemoryUsage()
getCursorMemoryUsage
in interface QueueViewMBean
public int getCursorPercentUsage()
getCursorPercentUsage
in interface QueueViewMBean
public boolean isCursorFull()
isCursorFull
in interface QueueViewMBean
public boolean isCacheEnabled()
isCacheEnabled
in interface QueueViewMBean
public Map<String,String> getMessageGroups()
getMessageGroups
in interface QueueViewMBean
public String getMessageGroupType()
getMessageGroupType
in interface QueueViewMBean
public void removeMessageGroup(String groupName)
removeMessageGroup
in interface QueueViewMBean
public void removeAllMessageGroups()
removeAllMessageGroups
in interface QueueViewMBean
public void pause()
pause
in interface QueueViewMBean
public void resume()
resume
in interface QueueViewMBean
public boolean isPaused()
isPaused
in interface QueueViewMBean
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.