public interface BrokerViewMBean extends Service
String getBrokerId()
String getBrokerName()
String getBrokerVersion()
long getUptimeMillis()
int getCurrentConnectionsCount()
long getTotalConnectionsCount()
void gc() throws Exception
Exceptionvoid resetStatistics()
void enableStatistics()
void disableStatistics()
boolean isStatisticsEnabled()
long getTotalEnqueueCount()
long getTotalDequeueCount()
long getTotalConsumerCount()
long getTotalProducerCount()
long getTotalMessageCount()
long getAverageMessageSize()
long getMaxMessageSize()
long getMinMessageSize()
int getMemoryPercentUsage()
long getMemoryLimit()
void setMemoryLimit(long limit)
int getStorePercentUsage()
long getStoreLimit()
void setStoreLimit(long limit)
int getTempPercentUsage()
long getTempLimit()
void setTempLimit(long limit)
int getJobSchedulerStorePercentUsage()
long getJobSchedulerStoreLimit()
void setJobSchedulerStoreLimit(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 restart() throws Exception
Exceptionvoid stopGracefully(String connectorName, String queueName, long timeout, long pollInterval) throws Exception
ExceptionObjectName[] getTopics()
ObjectName[] getQueues()
ObjectName[] getTemporaryTopics()
ObjectName[] getTemporaryQueues()
ObjectName[] getTopicSubscribers()
ObjectName[] getDurableTopicSubscribers()
ObjectName[] getInactiveDurableTopicSubscribers()
ObjectName[] getQueueSubscribers()
ObjectName[] getTemporaryTopicSubscribers()
ObjectName[] getTemporaryQueueSubscribers()
ObjectName[] getTopicProducers()
ObjectName[] getQueueProducers()
ObjectName[] getTemporaryTopicProducers()
ObjectName[] getTemporaryQueueProducers()
ObjectName[] getDynamicDestinationProducers()
String addConnector(String discoveryAddress) throws Exception
ExceptionString addNetworkConnector(String discoveryAddress) throws Exception
Exceptionboolean removeConnector(String connectorName) throws Exception
Exceptionboolean removeNetworkConnector(String connectorName) throws Exception
Exceptionvoid addTopic(String name) throws Exception
name - The name of the TopicExceptionvoid addQueue(String name) throws Exception
name - The name of the QueueExceptionvoid removeTopic(String name) throws Exception
name - The name of the TopicExceptionvoid removeQueue(String name) throws Exception
name - The name of the QueueExceptionObjectName createDurableSubscriber(String clientId, String subscriberName, String topicName, String selector) throws Exception
clientId - the JMS client IDsubscriberName - the durable subscriber nametopicName - the name of the topic to subscribe toselector - a selector or nullExceptionvoid destroyDurableSubscriber(String clientId, String subscriberName) throws Exception
clientId - the JMS client IDsubscriberName - the durable subscriber nameExceptionvoid reloadLog4jProperties() throws Throwable
ThrowableMap<String,String> getTransportConnectors()
String getTransportConnectorByType(String type)
String getDataDirectory()
ObjectName getJMSJobScheduler()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.