|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface DestinationViewMBean
Method Summary | |
---|---|
javax.management.openmbean.CompositeData[] |
browse()
|
javax.management.openmbean.CompositeData[] |
browse(java.lang.String selector)
|
javax.management.openmbean.TabularData |
browseAsTable()
|
javax.management.openmbean.TabularData |
browseAsTable(java.lang.String selector)
|
java.util.List<?> |
browseMessages()
Browses the current destination returning a list of messages |
java.util.List<?> |
browseMessages(java.lang.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()
|
java.lang.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 |
javax.management.ObjectName |
getSlowConsumerStrategy()
Returns the slow consumer strategy MBean for this destination |
javax.management.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. |
java.lang.String |
sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body)
Sends a TextMesage to the destination. |
java.lang.String |
sendTextMessage(java.util.Map<?,?> headers,
java.lang.String body,
java.lang.String user,
java.lang.String password)
|
java.lang.String |
sendTextMessage(java.lang.String body)
Sends a TextMesage to the destination. |
java.lang.String |
sendTextMessage(java.lang.String body,
java.lang.String user,
java.lang.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)
|
Method Detail |
---|
java.lang.String getName()
void resetStatistics()
long getEnqueueCount()
long getDispatchCount()
long getDequeueCount()
long getInFlightCount()
long getExpiredCount()
long getConsumerCount()
long getProducerCount()
long getQueueSize()
javax.management.openmbean.CompositeData[] browse() throws javax.management.openmbean.OpenDataException
javax.management.openmbean.OpenDataException
javax.management.openmbean.TabularData browseAsTable() throws javax.management.openmbean.OpenDataException
javax.management.openmbean.OpenDataException
javax.management.openmbean.CompositeData[] browse(java.lang.String selector) throws javax.management.openmbean.OpenDataException, javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
javax.management.openmbean.OpenDataException
javax.management.openmbean.TabularData browseAsTable(java.lang.String selector) throws javax.management.openmbean.OpenDataException, javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
javax.management.openmbean.OpenDataException
java.lang.String sendTextMessage(java.lang.String body) throws java.lang.Exception
body
- the text to send
java.lang.Exception
java.lang.String sendTextMessage(java.util.Map<?,?> headers, java.lang.String body) throws java.lang.Exception
headers
- the message headers and properties to set. Can only
container Strings maped to primitive types.body
- the text to send
java.lang.Exception
java.lang.String sendTextMessage(java.lang.String body, java.lang.String user, java.lang.String password) throws java.lang.Exception
body
- the text to senduser
- password
-
java.lang.Exception
java.lang.String sendTextMessage(java.util.Map<?,?> headers, java.lang.String body, java.lang.String user, java.lang.String password) throws java.lang.Exception
headers
- the message headers and properties to set. Can only
container Strings maped to primitive types.body
- the text to senduser
- password
-
java.lang.Exception
int getMemoryPercentUsage()
long getMemoryLimit()
void setMemoryLimit(long limit)
limit
- float getMemoryUsagePortion()
void setMemoryUsagePortion(float value)
value
- java.util.List<?> browseMessages() throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
java.util.List<?> browseMessages(java.lang.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 destinationjavax.management.ObjectName[] getSubscriptions() throws java.io.IOException, javax.management.MalformedObjectNameException
java.io.IOException
javax.management.MalformedObjectNameException
javax.management.ObjectName getSlowConsumerStrategy() throws java.io.IOException, javax.management.MalformedObjectNameException
java.io.IOException
javax.management.MalformedObjectNameException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |