public interface BrokerViewMBean extends Service
Modifier and Type | Method and Description |
---|---|
java.lang.String |
addConnector(java.lang.String discoveryAddress) |
java.lang.String |
addNetworkConnector(java.lang.String discoveryAddress) |
void |
addQueue(java.lang.String name)
Adds a Queue destination to the broker.
|
void |
addTopic(java.lang.String name)
Adds a Topic destination to the broker.
|
javax.management.ObjectName |
createDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName,
java.lang.String topicName,
java.lang.String selector)
Creates a new durable topic subscriber
|
void |
destroyDurableSubscriber(java.lang.String clientId,
java.lang.String subscriberName)
Destroys a durable subscriber
|
void |
disableStatistics() |
void |
enableStatistics() |
void |
gc()
The Broker will fush it's caches so that the garbage collector can
recalaim more memory.
|
java.lang.String |
getBrokerId() |
java.lang.String |
getBrokerName() |
java.lang.String |
getBrokerVersion() |
java.lang.String |
getDataDirectory() |
javax.management.ObjectName[] |
getDurableTopicSubscribers() |
javax.management.ObjectName[] |
getInactiveDurableTopicSubscribers() |
javax.management.ObjectName |
getJMSJobScheduler() |
long |
getMemoryLimit() |
int |
getMemoryPercentUsage() |
java.lang.String |
getOpenWireURL() |
javax.management.ObjectName[] |
getQueues() |
javax.management.ObjectName[] |
getQueueSubscribers() |
java.lang.String |
getSslURL() |
java.lang.String |
getStompSslURL() |
java.lang.String |
getStompURL() |
long |
getStoreLimit() |
int |
getStorePercentUsage() |
long |
getTempLimit() |
javax.management.ObjectName[] |
getTemporaryQueues() |
javax.management.ObjectName[] |
getTemporaryQueueSubscribers() |
javax.management.ObjectName[] |
getTemporaryTopics() |
javax.management.ObjectName[] |
getTemporaryTopicSubscribers() |
int |
getTempPercentUsage() |
javax.management.ObjectName[] |
getTopics() |
javax.management.ObjectName[] |
getTopicSubscribers() |
long |
getTotalConsumerCount() |
long |
getTotalDequeueCount() |
long |
getTotalEnqueueCount() |
long |
getTotalMessageCount() |
java.lang.String |
getVMURL() |
boolean |
isPersistent() |
boolean |
isSlave() |
boolean |
isStatisticsEnabled() |
void |
reloadLog4jProperties()
Reloads log4j.properties from the classpath.
|
boolean |
removeConnector(java.lang.String connectorName) |
boolean |
removeNetworkConnector(java.lang.String connectorName) |
void |
removeQueue(java.lang.String name)
Removes a Queue destination from the broker.
|
void |
removeTopic(java.lang.String name)
Removes a Topic destination from the broker.
|
void |
resetStatistics() |
void |
setMemoryLimit(long limit) |
void |
setStoreLimit(long limit) |
void |
setTempLimit(long limit) |
void |
stop()
Stop the broker and all it's components.
|
void |
stopGracefully(java.lang.String connectorName,
java.lang.String queueName,
long timeout,
long pollInterval) |
void |
terminateJVM(int exitCode)
Shuts down the JVM.
|
java.lang.String getBrokerId()
java.lang.String getBrokerName()
java.lang.String getBrokerVersion()
void gc() throws java.lang.Exception
java.lang.Exception
void resetStatistics()
void enableStatistics()
void disableStatistics()
boolean isStatisticsEnabled()
long getTotalEnqueueCount()
long getTotalDequeueCount()
long getTotalConsumerCount()
long getTotalMessageCount()
int getMemoryPercentUsage()
long getMemoryLimit()
void setMemoryLimit(long limit)
int getStorePercentUsage()
long getStoreLimit()
void setStoreLimit(long limit)
int getTempPercentUsage()
long getTempLimit()
void setTempLimit(long limit)
boolean isPersistent()
boolean isSlave()
void terminateJVM(int exitCode)
exitCode
- the exit code that will be reported by the JVM process
when it exits.void stop() throws java.lang.Exception
void stopGracefully(java.lang.String connectorName, java.lang.String queueName, long timeout, long pollInterval) throws java.lang.Exception
java.lang.Exception
javax.management.ObjectName[] getTopics()
javax.management.ObjectName[] getQueues()
javax.management.ObjectName[] getTemporaryTopics()
javax.management.ObjectName[] getTemporaryQueues()
javax.management.ObjectName[] getTopicSubscribers()
javax.management.ObjectName[] getDurableTopicSubscribers()
javax.management.ObjectName[] getInactiveDurableTopicSubscribers()
javax.management.ObjectName[] getQueueSubscribers()
javax.management.ObjectName[] getTemporaryTopicSubscribers()
javax.management.ObjectName[] getTemporaryQueueSubscribers()
java.lang.String addConnector(java.lang.String discoveryAddress) throws java.lang.Exception
java.lang.Exception
java.lang.String addNetworkConnector(java.lang.String discoveryAddress) throws java.lang.Exception
java.lang.Exception
boolean removeConnector(java.lang.String connectorName) throws java.lang.Exception
java.lang.Exception
boolean removeNetworkConnector(java.lang.String connectorName) throws java.lang.Exception
java.lang.Exception
void addTopic(java.lang.String name) throws java.lang.Exception
name
- The name of the Topicjava.lang.Exception
void addQueue(java.lang.String name) throws java.lang.Exception
name
- The name of the Queuejava.lang.Exception
void removeTopic(java.lang.String name) throws java.lang.Exception
name
- The name of the Topicjava.lang.Exception
void removeQueue(java.lang.String name) throws java.lang.Exception
name
- The name of the Queuejava.lang.Exception
javax.management.ObjectName createDurableSubscriber(java.lang.String clientId, java.lang.String subscriberName, java.lang.String topicName, java.lang.String selector) throws java.lang.Exception
clientId
- the JMS client IDsubscriberName
- the durable subscriber nametopicName
- the name of the topic to subscribe toselector
- a selector or nulljava.lang.Exception
void destroyDurableSubscriber(java.lang.String clientId, java.lang.String subscriberName) throws java.lang.Exception
clientId
- the JMS client IDsubscriberName
- the durable subscriber namejava.lang.Exception
void reloadLog4jProperties() throws java.lang.Throwable
java.lang.Throwable
java.lang.String getOpenWireURL()
java.lang.String getStompURL()
java.lang.String getSslURL()
java.lang.String getStompSslURL()
java.lang.String getVMURL()
java.lang.String getDataDirectory()
javax.management.ObjectName getJMSJobScheduler()
Copyright © 2005-2012. All Rights Reserved.