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(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, gc, getAverageEnqueueTime, getBlockedProducerWarningInterval, getConsumerCount, getDequeueCount, getDispatchCount, getEnqueueCount, getExpiredCount, getInFlightCount, getMaxAuditDepth, getMaxEnqueueTime, getMaxPageSize, getMaxProducersToAudit, getMemoryLimit, getMemoryPercentUsage, getMemoryUsagePortion, getMessagesCached, getMinEnqueueTime, getName, getProducerCount, getQueueSize, getSlowConsumerStrategy, getSubscriptions, isEnableAudit, isPrioritizedMessages, isProducerFlowControl, isUseCache, resetStatistics, sendTextMessage, sendTextMessage, sendTextMessage, sendTextMessage, 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, 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
public QueueView(ManagedRegionBroker broker, Queue destination)
public javax.management.openmbean.CompositeData getMessage(java.lang.String messageId) throws javax.management.openmbean.OpenDataException
QueueViewMBean
getMessage
in interface QueueViewMBean
messageId
- the message id of the message to retrievejavax.management.openmbean.OpenDataException
public void purge() throws java.lang.Exception
QueueViewMBean
purge
in interface QueueViewMBean
java.lang.Exception
public boolean removeMessage(java.lang.String messageId) throws java.lang.Exception
QueueViewMBean
removeMessage
in interface QueueViewMBean
java.lang.Exception
public int removeMatchingMessages(java.lang.String selector) throws java.lang.Exception
QueueViewMBean
removeMatchingMessages
in interface QueueViewMBean
java.lang.Exception
public int removeMatchingMessages(java.lang.String selector, int maximumMessages) throws java.lang.Exception
QueueViewMBean
removeMatchingMessages
in interface QueueViewMBean
java.lang.Exception
public boolean copyMessageTo(java.lang.String messageId, java.lang.String destinationName) throws java.lang.Exception
QueueViewMBean
copyMessageTo
in interface QueueViewMBean
java.lang.Exception
public int copyMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName) throws java.lang.Exception
QueueViewMBean
copyMatchingMessagesTo
in interface QueueViewMBean
java.lang.Exception
public int copyMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName, int maximumMessages) throws java.lang.Exception
QueueViewMBean
copyMatchingMessagesTo
in interface QueueViewMBean
java.lang.Exception
public boolean moveMessageTo(java.lang.String messageId, java.lang.String destinationName) throws java.lang.Exception
QueueViewMBean
moveMessageTo
in interface QueueViewMBean
java.lang.Exception
public int moveMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName) throws java.lang.Exception
QueueViewMBean
moveMatchingMessagesTo
in interface QueueViewMBean
java.lang.Exception
public int moveMatchingMessagesTo(java.lang.String selector, java.lang.String destinationName, int maximumMessages) throws java.lang.Exception
QueueViewMBean
moveMatchingMessagesTo
in interface QueueViewMBean
java.lang.Exception
public boolean retryMessage(java.lang.String messageId) throws java.lang.Exception
retryMessage
in interface QueueViewMBean
java.lang.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
Copyright © 2005-2012. All Rights Reserved.