public interface DestinationViewMBean
Modifier and Type | Method and Description |
---|---|
CompositeData[] |
browse() |
CompositeData[] |
browse(String selector) |
TabularData |
browseAsTable() |
TabularData |
browseAsTable(String selector) |
List<?> |
browseMessages()
Browses the current destination returning a list of messages
|
List<?> |
browseMessages(String selector)
Browses the current destination with the given selector returning a list
of messages
|
double |
getAverageEnqueueTime() |
long |
getBlockedProducerWarningInterval() |
long |
getConsumerCount()
Returns the number of consumers subscribed this destination.
|
long |
getDequeueCount()
Returns the number of messages that have been acknowledged from the
destination.
|
long |
getDispatchCount()
Returns the number of messages that have been delivered (potentially not
acknowledged) to consumers.
|
long |
getEnqueueCount()
Returns the number of messages that have been sent to the destination.
|
long |
getExpiredCount()
Returns the number of messages that have expired
|
long |
getInFlightCount()
Returns the number of messages that have been dispatched but not
acknowledged
|
int |
getMaxAuditDepth() |
long |
getMaxEnqueueTime() |
int |
getMaxPageSize() |
int |
getMaxProducersToAudit() |
long |
getMemoryLimit() |
int |
getMemoryPercentUsage() |
float |
getMemoryUsagePortion() |
long |
getMinEnqueueTime() |
String |
getName()
Returns the name of this destination
|
long |
getProducerCount() |
long |
getQueueSize()
Returns the number of messages in this destination which are yet to be
consumed
|
ObjectName |
getSlowConsumerStrategy()
Returns the slow consumer strategy MBean for this destination
|
ObjectName[] |
getSubscriptions()
Returns all the current subscription MBeans matching this destination
|
boolean |
isAlwaysRetroactive() |
boolean |
isPrioritizedMessages() |
boolean |
isProducerFlowControl() |
boolean |
isUseCache() |
void |
resetStatistics()
Resets the managment counters.
|
String |
sendTextMessage(Map<?,?> headers,
String body)
Sends a TextMesage to the destination.
|
String |
sendTextMessage(Map<?,?> headers,
String body,
String user,
String password) |
String |
sendTextMessage(String body)
Sends a TextMesage to the destination.
|
String |
sendTextMessage(String body,
String user,
String password)
Sends a TextMesage to the destination.
|
void |
setAlwaysRetroactive(boolean alwaysRetroactive) |
void |
setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
Set's the interval at which warnings about producers being blocked by
resource usage will be triggered.
|
void |
setMaxAuditDepth(int maxAuditDepth) |
void |
setMaxPageSize(int pageSize) |
void |
setMaxProducersToAudit(int maxProducersToAudit) |
void |
setMemoryLimit(long limit)
set the amount of memory allocated to this destination
|
void |
setMemoryUsagePortion(float value)
set the portion of memory from the broker memory limit for this destination
|
void |
setProducerFlowControl(boolean producerFlowControl) |
void |
setUseCache(boolean value) |
void resetStatistics()
long getEnqueueCount()
long getDispatchCount()
long getDequeueCount()
long getInFlightCount()
long getExpiredCount()
long getConsumerCount()
long getProducerCount()
long getQueueSize()
CompositeData[] browse() throws OpenDataException
OpenDataException
TabularData browseAsTable() throws OpenDataException
OpenDataException
CompositeData[] browse(String selector) throws OpenDataException, javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
OpenDataException
TabularData browseAsTable(String selector) throws OpenDataException, javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
OpenDataException
String sendTextMessage(String body) throws Exception
body
- the text to sendException
String sendTextMessage(Map<?,?> headers, String body) throws Exception
headers
- the message headers and properties to set. Can only
container Strings maped to primitive types.body
- the text to sendException
String sendTextMessage(String body, String user, String password) throws Exception
body
- the text to senduser
- password
- Exception
String sendTextMessage(Map<?,?> headers, String body, String user, String password) throws Exception
headers
- the message headers and properties to set. Can only
container Strings maped to primitive types.body
- the text to senduser
- password
- Exception
int getMemoryPercentUsage()
long getMemoryLimit()
void setMemoryLimit(long limit)
limit
- float getMemoryUsagePortion()
void setMemoryUsagePortion(float value)
value
- List<?> browseMessages() throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
List<?> browseMessages(String selector) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
long getMaxEnqueueTime()
long getMinEnqueueTime()
double getAverageEnqueueTime()
boolean isProducerFlowControl()
void setProducerFlowControl(boolean producerFlowControl)
producerFlowControl
- the producerFlowControl to setboolean isAlwaysRetroactive()
void setAlwaysRetroactive(boolean alwaysRetroactive)
alwaysRetroactive
- set as always retroActivevoid setBlockedProducerWarningInterval(long blockedProducerWarningInterval)
blockedProducerWarningInterval
- the interval at which warning about
blocked producers will be triggered.long getBlockedProducerWarningInterval()
int getMaxProducersToAudit()
void setMaxProducersToAudit(int maxProducersToAudit)
maxProducersToAudit
- the maxProducersToAudit to setint getMaxAuditDepth()
void setMaxAuditDepth(int maxAuditDepth)
maxAuditDepth
- the maxAuditDepth to setint getMaxPageSize()
void setMaxPageSize(int pageSize)
pageSize
- Set the maximum number of messages to page into the destinationboolean isUseCache()
boolean isPrioritizedMessages()
void setUseCache(boolean value)
value
- enable/disable caching on the destinationObjectName[] getSubscriptions() throws IOException, MalformedObjectNameException
IOException
MalformedObjectNameException
ObjectName getSlowConsumerStrategy() throws IOException, MalformedObjectNameException
IOException
MalformedObjectNameException
Copyright © 2005–2015. All rights reserved.