public class MessageBrokerView extends Object
Constructor and Description |
---|
MessageBrokerView(BrokerService brokerService)
Create a view of a running Broker
|
MessageBrokerView(String brokerName)
Create a view of a running Broker
|
Modifier and Type | Method and Description |
---|---|
String |
getBrokerId() |
String |
getBrokerName() |
BrokerService |
getBrokerService() |
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(String destinationName)
It will be assumed the destinationName is prepended with topic:// or queue:// - but
will default to a Queue
|
BrokerDestinationView |
getDestinationView(String destinationName,
byte type)
Get the BrokerDestinationView associated with destination
|
int |
getJobSchedulerStorePercentUsage() |
int |
getMemoryPercentUsage() |
BrokerDestinationView |
getQueueDestinationView(String destinationName)
Get the BrokerDestinationView associated with the queue
|
Set<ActiveMQQueue> |
getQueues()
Retrieve a set of all Queues be used by the Broker
|
int |
getStorePercentUsage() |
int |
getTempPercentUsage() |
Set<ActiveMQTempQueue> |
getTempQueues()
Retrieve a set of all TemporaryQueues be used by the Broker
|
Set<ActiveMQTempTopic> |
getTempTopics()
Retrieve a set of all TemporaryTopics be used by the Broker
|
BrokerDestinationView |
getTopicDestinationView(String destinationName)
Get the BrokerDestinationView associated with the topic
|
Set<ActiveMQTopic> |
getTopics()
Retrieve a set of all Topics be used by the Broker
|
boolean |
isPersistent() |
public MessageBrokerView(BrokerService brokerService)
brokerService
- public MessageBrokerView(String brokerName)
brokerName
- public String getBrokerName()
public String getBrokerId()
public int getMemoryPercentUsage()
public int getStorePercentUsage()
public int getTempPercentUsage()
public int getJobSchedulerStorePercentUsage()
public boolean isPersistent()
public BrokerService getBrokerService()
public Set<ActiveMQDestination> getDestinations()
public Set<ActiveMQTopic> getTopics()
public Set<ActiveMQQueue> getQueues()
public Set<ActiveMQTempTopic> getTempTopics()
public Set<ActiveMQTempQueue> getTempQueues()
public BrokerDestinationView getDestinationView(String destinationName) throws Exception
destinationName
- Exception
public BrokerDestinationView getTopicDestinationView(String destinationName) throws Exception
destinationName
- Exception
public BrokerDestinationView getQueueDestinationView(String destinationName) throws Exception
destinationName
- Exception
public BrokerDestinationView getDestinationView(String destinationName, byte type) throws Exception
destinationName
- type
- expects either ActiveMQDestination.QUEUE_TYPE, ActiveMQDestination.TOPIC_TYPE etcException
public BrokerDestinationView getDestinationView(ActiveMQDestination activeMQDestination) throws Exception
activeMQDestination
- Exception
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.