org.apache.activemq.broker.jmx
Class BrokerView

java.lang.Object
  org.apache.activemq.broker.jmx.BrokerView

All Implemented Interfaces:

BrokerViewMBean, Service

public class BrokerView
extends java.lang.Object
implements BrokerViewMBean

Constructor Summary

BrokerView(BrokerService brokerService, ManagedRegionBroker managedBroker)

Method Summary

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 flush it's caches so that the garbage collector can reclaim more memory.
ManagedRegionBroker	getBroker()
java.lang.String	getBrokerId()
java.lang.String	getBrokerName()
java.lang.String	getBrokerVersion()
java.lang.String	getDataDirectory()
javax.management.ObjectName[]	getDurableTopicSubscribers()
javax.management.ObjectName[]	getDynamicDestinationProducers()
javax.management.ObjectName[]	getInactiveDurableTopicSubscribers()
javax.management.ObjectName	getJMSJobScheduler()
long	getMemoryLimit()
int	getMemoryPercentUsage()
java.lang.String	getOpenWireURL()
javax.management.ObjectName[]	getQueueProducers()
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[]	getTemporaryQueueProducers()
javax.management.ObjectName[]	getTemporaryQueues()
javax.management.ObjectName[]	getTemporaryQueueSubscribers()
javax.management.ObjectName[]	getTemporaryTopicProducers()
javax.management.ObjectName[]	getTemporaryTopics()
javax.management.ObjectName[]	getTemporaryTopicSubscribers()
int	getTempPercentUsage()
javax.management.ObjectName[]	getTopicProducers()
javax.management.ObjectName[]	getTopics()
javax.management.ObjectName[]	getTopicSubscribers()
long	getTotalConsumerCount()
long	getTotalDequeueCount()
long	getTotalEnqueueCount()
long	getTotalMessageCount()
long	getTotalMessagesCached()
long	getTotalProducerCount()
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	setBroker(ManagedRegionBroker broker)
void	setJMSJobScheduler(javax.management.ObjectName name)
void	setMemoryLimit(long limit)
void	setStoreLimit(long limit)
void	setTempLimit(long limit)
void	start()
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BrokerView

public BrokerView(BrokerService brokerService,
                  ManagedRegionBroker managedBroker)
           throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getBroker

public ManagedRegionBroker getBroker()

setBroker

public void setBroker(ManagedRegionBroker broker)

getBrokerId

public java.lang.String getBrokerId()

Specified by:

getBrokerId in interface BrokerViewMBean

Returns:

The unique id of the broker.

getBrokerName

public java.lang.String getBrokerName()

Specified by:

getBrokerName in interface BrokerViewMBean

Returns:

The name of the broker.

getBrokerVersion

public java.lang.String getBrokerVersion()

Specified by:

getBrokerVersion in interface BrokerViewMBean

Returns:

The name of the broker.

gc

public void gc()
        throws java.lang.Exception

Description copied from interface: BrokerViewMBean

The Broker will flush it's caches so that the garbage collector can reclaim more memory.

Specified by:

gc in interface BrokerViewMBean

Throws:

java.lang.Exception

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Service

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Stop the broker and all it's components.

Specified by:

stop in interface BrokerViewMBean

Specified by:

stop in interface Service

Throws:

java.lang.Exception

stopGracefully

public void stopGracefully(java.lang.String connectorName,
                           java.lang.String queueName,
                           long timeout,
                           long pollInterval)
                    throws java.lang.Exception

Specified by:

stopGracefully in interface BrokerViewMBean

Throws:

java.lang.Exception

getTotalEnqueueCount

public long getTotalEnqueueCount()

Specified by:

getTotalEnqueueCount in interface BrokerViewMBean

getTotalDequeueCount

public long getTotalDequeueCount()

Specified by:

getTotalDequeueCount in interface BrokerViewMBean

getTotalConsumerCount

public long getTotalConsumerCount()

Specified by:

getTotalConsumerCount in interface BrokerViewMBean

getTotalProducerCount

public long getTotalProducerCount()

Specified by:

getTotalProducerCount in interface BrokerViewMBean

getTotalMessageCount

public long getTotalMessageCount()

Specified by:

getTotalMessageCount in interface BrokerViewMBean

getTotalMessagesCached

public long getTotalMessagesCached()

getMemoryPercentUsage

public int getMemoryPercentUsage()

Specified by:

getMemoryPercentUsage in interface BrokerViewMBean

getMemoryLimit

public long getMemoryLimit()

Specified by:

getMemoryLimit in interface BrokerViewMBean

setMemoryLimit

public void setMemoryLimit(long limit)

Specified by:

setMemoryLimit in interface BrokerViewMBean

getStoreLimit

public long getStoreLimit()

Specified by:

getStoreLimit in interface BrokerViewMBean

getStorePercentUsage

public int getStorePercentUsage()

Specified by:

getStorePercentUsage in interface BrokerViewMBean

getTempLimit

public long getTempLimit()

Specified by:

getTempLimit in interface BrokerViewMBean

getTempPercentUsage

public int getTempPercentUsage()

Specified by:

getTempPercentUsage in interface BrokerViewMBean

setStoreLimit

public void setStoreLimit(long limit)

Specified by:

setStoreLimit in interface BrokerViewMBean

setTempLimit

public void setTempLimit(long limit)

Specified by:

setTempLimit in interface BrokerViewMBean

resetStatistics

public void resetStatistics()

Specified by:

resetStatistics in interface BrokerViewMBean

enableStatistics

public void enableStatistics()

Specified by:

enableStatistics in interface BrokerViewMBean

disableStatistics

public void disableStatistics()

Specified by:

disableStatistics in interface BrokerViewMBean

isStatisticsEnabled

public boolean isStatisticsEnabled()

Specified by:

isStatisticsEnabled in interface BrokerViewMBean

isPersistent

public boolean isPersistent()

Specified by:

isPersistent in interface BrokerViewMBean

isSlave

public boolean isSlave()

Specified by:

isSlave in interface BrokerViewMBean

terminateJVM

public void terminateJVM(int exitCode)

Description copied from interface: BrokerViewMBean

Shuts down the JVM.

Specified by:

terminateJVM in interface BrokerViewMBean

Parameters:

exitCode - the exit code that will be reported by the JVM process when it exits.

getTopics

public javax.management.ObjectName[] getTopics()

Specified by:

getTopics in interface BrokerViewMBean

getQueues

public javax.management.ObjectName[] getQueues()

Specified by:

getQueues in interface BrokerViewMBean

getTemporaryTopics

public javax.management.ObjectName[] getTemporaryTopics()

Specified by:

getTemporaryTopics in interface BrokerViewMBean

getTemporaryQueues

public javax.management.ObjectName[] getTemporaryQueues()

Specified by:

getTemporaryQueues in interface BrokerViewMBean

getTopicSubscribers

public javax.management.ObjectName[] getTopicSubscribers()

Specified by:

getTopicSubscribers in interface BrokerViewMBean

getDurableTopicSubscribers

public javax.management.ObjectName[] getDurableTopicSubscribers()

Specified by:

getDurableTopicSubscribers in interface BrokerViewMBean

getQueueSubscribers

public javax.management.ObjectName[] getQueueSubscribers()

Specified by:

getQueueSubscribers in interface BrokerViewMBean

getTemporaryTopicSubscribers

public javax.management.ObjectName[] getTemporaryTopicSubscribers()

Specified by:

getTemporaryTopicSubscribers in interface BrokerViewMBean

getTemporaryQueueSubscribers

public javax.management.ObjectName[] getTemporaryQueueSubscribers()

Specified by:

getTemporaryQueueSubscribers in interface BrokerViewMBean

getInactiveDurableTopicSubscribers

public javax.management.ObjectName[] getInactiveDurableTopicSubscribers()

Specified by:

getInactiveDurableTopicSubscribers in interface BrokerViewMBean

getTopicProducers

public javax.management.ObjectName[] getTopicProducers()

Specified by:

getTopicProducers in interface BrokerViewMBean

getQueueProducers

public javax.management.ObjectName[] getQueueProducers()

Specified by:

getQueueProducers in interface BrokerViewMBean

getTemporaryTopicProducers

public javax.management.ObjectName[] getTemporaryTopicProducers()

Specified by:

getTemporaryTopicProducers in interface BrokerViewMBean

getTemporaryQueueProducers

public javax.management.ObjectName[] getTemporaryQueueProducers()

Specified by:

getTemporaryQueueProducers in interface BrokerViewMBean

getDynamicDestinationProducers

public javax.management.ObjectName[] getDynamicDestinationProducers()

Specified by:

getDynamicDestinationProducers in interface BrokerViewMBean

addConnector

public java.lang.String addConnector(java.lang.String discoveryAddress)
                              throws java.lang.Exception

Specified by:

addConnector in interface BrokerViewMBean

Throws:

java.lang.Exception

addNetworkConnector

public java.lang.String addNetworkConnector(java.lang.String discoveryAddress)
                                     throws java.lang.Exception

Specified by:

addNetworkConnector in interface BrokerViewMBean

Throws:

java.lang.Exception

removeConnector

public boolean removeConnector(java.lang.String connectorName)
                        throws java.lang.Exception

Specified by:

removeConnector in interface BrokerViewMBean

Throws:

java.lang.Exception

removeNetworkConnector

public boolean removeNetworkConnector(java.lang.String connectorName)
                               throws java.lang.Exception

Specified by:

removeNetworkConnector in interface BrokerViewMBean

Throws:

java.lang.Exception

addTopic

public void addTopic(java.lang.String name)
              throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Adds a Topic destination to the broker.

Specified by:

addTopic in interface BrokerViewMBean

Parameters:

name - The name of the Topic

Throws:

java.lang.Exception

addQueue

public void addQueue(java.lang.String name)
              throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Adds a Queue destination to the broker.

Specified by:

addQueue in interface BrokerViewMBean

Parameters:

name - The name of the Queue

Throws:

java.lang.Exception

removeTopic

public void removeTopic(java.lang.String name)
                 throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Removes a Topic destination from the broker.

Specified by:

removeTopic in interface BrokerViewMBean

Parameters:

name - The name of the Topic

Throws:

java.lang.Exception

removeQueue

public void removeQueue(java.lang.String name)
                 throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Removes a Queue destination from the broker.

Specified by:

removeQueue in interface BrokerViewMBean

Parameters:

name - The name of the Queue

Throws:

java.lang.Exception

createDurableSubscriber

public javax.management.ObjectName createDurableSubscriber(java.lang.String clientId,
                                                           java.lang.String subscriberName,
                                                           java.lang.String topicName,
                                                           java.lang.String selector)
                                                    throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Creates a new durable topic subscriber

Specified by:

createDurableSubscriber in interface BrokerViewMBean

Parameters:

clientId - the JMS client ID

subscriberName - the durable subscriber name

topicName - the name of the topic to subscribe to

selector - a selector or null

Returns:

the object name of the MBean registered in JMX

Throws:

java.lang.Exception

destroyDurableSubscriber

public void destroyDurableSubscriber(java.lang.String clientId,
                                     java.lang.String subscriberName)
                              throws java.lang.Exception

Description copied from interface: BrokerViewMBean

Destroys a durable subscriber

Specified by:

destroyDurableSubscriber in interface BrokerViewMBean

Parameters:

clientId - the JMS client ID

subscriberName - the durable subscriber name

Throws:

java.lang.Exception

reloadLog4jProperties

public void reloadLog4jProperties()
                           throws java.lang.Throwable

Description copied from interface: BrokerViewMBean

Reloads log4j.properties from the classpath. This methods calls org.apache.activemq.transport.TransportLoggerControl.reloadLog4jProperties

Specified by:

reloadLog4jProperties in interface BrokerViewMBean

Throws:

java.lang.Throwable

getOpenWireURL

public java.lang.String getOpenWireURL()

Specified by:

getOpenWireURL in interface BrokerViewMBean

getStompURL

public java.lang.String getStompURL()

Specified by:

getStompURL in interface BrokerViewMBean

getSslURL

public java.lang.String getSslURL()

Specified by:

getSslURL in interface BrokerViewMBean

getStompSslURL

public java.lang.String getStompSslURL()

Specified by:

getStompSslURL in interface BrokerViewMBean

getVMURL

public java.lang.String getVMURL()

Specified by:

getVMURL in interface BrokerViewMBean

getDataDirectory

public java.lang.String getDataDirectory()

Specified by:

getDataDirectory in interface BrokerViewMBean

getJMSJobScheduler

public javax.management.ObjectName getJMSJobScheduler()

Specified by:

getJMSJobScheduler in interface BrokerViewMBean

setJMSJobScheduler

public void setJMSJobScheduler(javax.management.ObjectName name)