org.apache.activemq.broker.view

Class MessageBrokerView

java.lang.Object

org.apache.activemq.broker.view.MessageBrokerView

public class MessageBrokerView
extends java.lang.Object

A view into the running Broker

Constructor Summary

Constructors

Constructor and Description
MessageBrokerView(BrokerService brokerService) Create a view of a running Broker
MessageBrokerView(java.lang.String brokerName) Create a view of a running Broker

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getBrokerId()
java.lang.String	getBrokerName()
BrokerService	getBrokerService()
java.util.Set<ActiveMQDestination>	getDestinations() Retrieve a set of all Destinations be used by the Broker
BrokerDestinationView	getDestinationView(ActiveMQDestination activeMQDestination) Get the BrokerDestinationView associated with destination
BrokerDestinationView	getDestinationView(java.lang.String destinationName) It will be assumed the destinationName is prepended with topic:// or queue:// - but will default to a Queue
BrokerDestinationView	getDestinationView(java.lang.String destinationName, byte type) Get the BrokerDestinationView associated with destination
int	getJobSchedulerStorePercentUsage()
int	getMemoryPercentUsage()
BrokerDestinationView	getQueueDestinationView(java.lang.String destinationName) Get the BrokerDestinationView associated with the queue
java.util.Set<ActiveMQQueue>	getQueues() Retrieve a set of all Queues be used by the Broker
int	getStorePercentUsage()
int	getTempPercentUsage()
java.util.Set<ActiveMQTempQueue>	getTempQueues() Retrieve a set of all TemporaryQueues be used by the Broker
java.util.Set<ActiveMQTempTopic>	getTempTopics() Retrieve a set of all TemporaryTopics be used by the Broker
BrokerDestinationView	getTopicDestinationView(java.lang.String destinationName) Get the BrokerDestinationView associated with the topic
java.util.Set<ActiveMQTopic>	getTopics() Retrieve a set of all Topics be used by the Broker
boolean	isPersistent()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageBrokerView

public MessageBrokerView(BrokerService brokerService)

Create a view of a running Broker

Parameters:

brokerService -

MessageBrokerView

public MessageBrokerView(java.lang.String brokerName)

Create a view of a running Broker

Parameters:

brokerName -

Method Detail

getBrokerName

public java.lang.String getBrokerName()

Returns:

the brokerName

getBrokerId

public java.lang.String getBrokerId()

Returns:

the unique id of the Broker

getMemoryPercentUsage

public int getMemoryPercentUsage()

Returns:

the memory used by the Broker as a percentage

getStorePercentUsage

public int getStorePercentUsage()

Returns:

the space used by the Message Store as a percentage

getTempPercentUsage

public int getTempPercentUsage()

Returns:

the space used by the store for temporary messages as a percentage

getJobSchedulerStorePercentUsage

public int getJobSchedulerStorePercentUsage()

Returns:

the space used by the store of scheduled messages

isPersistent

public boolean isPersistent()

Returns:

true if the Broker isn't using an in-memory store only for messages

getBrokerService

public BrokerService getBrokerService()

getDestinations

public java.util.Set<ActiveMQDestination> getDestinations()

Retrieve a set of all Destinations be used by the Broker

Returns:

all Destinations

getTopics

public java.util.Set<ActiveMQTopic> getTopics()

Retrieve a set of all Topics be used by the Broker

Returns:

all Topics

getQueues

public java.util.Set<ActiveMQQueue> getQueues()

Retrieve a set of all Queues be used by the Broker

Returns:

all Queues

getTempTopics

public java.util.Set<ActiveMQTempTopic> getTempTopics()

Retrieve a set of all TemporaryTopics be used by the Broker

Returns:

all TemporaryTopics

getTempQueues

public java.util.Set<ActiveMQTempQueue> getTempQueues()

Retrieve a set of all TemporaryQueues be used by the Broker

Returns:

all TemporaryQueues

getDestinationView

public BrokerDestinationView getDestinationView(java.lang.String destinationName)
                                         throws java.lang.Exception

It will be assumed the destinationName is prepended with topic:// or queue:// - but will default to a Queue

Parameters:

destinationName -

Returns:

the BrokerDestinationView associated with the destinationName

Throws:

java.lang.Exception

getTopicDestinationView

public BrokerDestinationView getTopicDestinationView(java.lang.String destinationName)
                                              throws java.lang.Exception

Get the BrokerDestinationView associated with the topic

Parameters:

destinationName -

Returns:

BrokerDestinationView

Throws:

java.lang.Exception

getQueueDestinationView

public BrokerDestinationView getQueueDestinationView(java.lang.String destinationName)
                                              throws java.lang.Exception

Get the BrokerDestinationView associated with the queue

Parameters:

destinationName -

Returns:

BrokerDestinationView

Throws:

java.lang.Exception

getDestinationView

public BrokerDestinationView getDestinationView(java.lang.String destinationName,
                                       byte type)
                                         throws java.lang.Exception

Get the BrokerDestinationView associated with destination

Parameters:

destinationName -

type - expects either ActiveMQDestination.QUEUE_TYPE, ActiveMQDestination.TOPIC_TYPE etc

Returns:

BrokerDestinationView

Throws:

java.lang.Exception

getDestinationView

public BrokerDestinationView getDestinationView(ActiveMQDestination activeMQDestination)
                                         throws java.lang.Exception

Get the BrokerDestinationView associated with destination

Parameters:

activeMQDestination -

Returns:

BrokerDestinationView

Throws:

java.lang.Exception