public class JmxTemplateBrokerFacade extends Object implements BrokerFacade
Constructor and Description |
---|
JmxTemplateBrokerFacade(io.fabric8.service.JmxTemplateSupport template) |
Modifier and Type | Method and Description |
---|---|
<T> T |
execute(BrokerFacadeCallback<T> callback)
Executes a JMX operation on a BrokerFacade
|
BrokerViewFacade |
getBrokerAdmin()
Admin view of the broker.
|
String |
getBrokerName()
The name of the active broker (f.e.
|
BrokerFacade[] |
getBrokers()
Returns all the available brokers.
|
ConnectionViewFacade |
getConnection(String connectionName)
A specific connection to the broker.
|
Collection<ConnectionViewFacade> |
getConnections()
All connections to all transport connectors of the broker.
|
Collection<String> |
getConnections(String connectorName)
The names of all connections to a specific transport connectors of the
broker.
|
ConnectorViewFacade |
getConnector(String name)
A transport connectors.
|
Collection<String> |
getConnectors()
The names of all transport connectors of the broker (f.e.
|
Collection<SubscriptionViewFacade> |
getConsumersOnConnection(String connectionName)
Returns all consumers of a connection.
|
Collection<DurableSubscriptionViewFacade> |
getDurableTopicSubscribers()
Active durable subscribers to topics of the broker.
|
String |
getId() |
Collection<DurableSubscriptionViewFacade> |
getInactiveDurableTopicSubscribers()
Inactive durable subscribers to topics of the broker.
|
JobSchedulerViewFacade |
getJobScheduler()
Get the JobScheduler MBean
|
Collection<NetworkBridgeViewFacade> |
getNetworkBridges()
The brokers network bridges.
|
Collection<NetworkConnectorViewFacade> |
getNetworkConnectors()
The brokers network connectors.
|
QueueViewFacade |
getQueue(String name)
Get the view of the queue with the specified name.
|
Collection<SubscriptionViewFacade> |
getQueueConsumers(String queueName)
All active consumers of a queue.
|
Collection<ProducerViewFacade> |
getQueueProducers(String queueName)
Returns the producers available on the given queue
|
Collection<QueueViewFacade> |
getQueues()
All queues known to the broker.
|
Collection<JobFacade> |
getScheduledJobs()
Get the JobScheduler MBean
|
TopicViewFacade |
getTopic(String name)
Get the view of the topic with the specified name.
|
Collection<SubscriptionViewFacade> |
getTopicConsumers(String topicName)
Returns the consumers available on the given topic
|
Collection<DurableSubscriptionViewFacade> |
getTopicDurableConsumers(String topicName)
Returns the durable consumers available on the given topic
|
Collection<ProducerViewFacade> |
getTopicProducers(String topicName)
Returns the producers available on the given topic
|
Collection<TopicViewFacade> |
getTopics()
All topics known to the broker.
|
boolean |
isJobSchedulerStarted() |
void |
purgeQueue(org.apache.activemq.command.ActiveMQDestination destination)
Purges the given destination
|
public JmxTemplateBrokerFacade(io.fabric8.service.JmxTemplateSupport template)
public <T> T execute(BrokerFacadeCallback<T> callback)
public String getId() throws Exception
getId
in interface BrokerFacade
Exception
public BrokerFacade[] getBrokers() throws Exception
BrokerFacade
getBrokers
in interface BrokerFacade
null
Exception
public BrokerViewFacade getBrokerAdmin() throws Exception
BrokerFacade
getBrokerAdmin
in interface BrokerFacade
null
Exception
public String getBrokerName() throws Exception
BrokerFacade
getBrokerName
in interface BrokerFacade
null
Exception
public Collection<QueueViewFacade> getQueues() throws Exception
BrokerFacade
getQueues
in interface BrokerFacade
null
Exception
public Collection<TopicViewFacade> getTopics() throws Exception
BrokerFacade
getTopics
in interface BrokerFacade
null
Exception
public Collection<SubscriptionViewFacade> getQueueConsumers(String queueName) throws Exception
BrokerFacade
getQueueConsumers
in interface BrokerFacade
queueName
- the name of the queue, not null
null
Exception
public Collection<SubscriptionViewFacade> getTopicConsumers(String topicName) throws Exception
BrokerFacade
getTopicConsumers
in interface BrokerFacade
Exception
public Collection<DurableSubscriptionViewFacade> getTopicDurableConsumers(String topicName) throws Exception
BrokerFacade
getTopicDurableConsumers
in interface BrokerFacade
Exception
public Collection<DurableSubscriptionViewFacade> getDurableTopicSubscribers() throws Exception
BrokerFacade
getDurableTopicSubscribers
in interface BrokerFacade
null
Exception
public Collection<DurableSubscriptionViewFacade> getInactiveDurableTopicSubscribers() throws Exception
BrokerFacade
getInactiveDurableTopicSubscribers
in interface BrokerFacade
null
Exception
public Collection<ProducerViewFacade> getQueueProducers(String queueName) throws Exception
BrokerFacade
getQueueProducers
in interface BrokerFacade
Exception
public Collection<ProducerViewFacade> getTopicProducers(String topicName) throws Exception
BrokerFacade
getTopicProducers
in interface BrokerFacade
Exception
public Collection<String> getConnectors() throws Exception
BrokerFacade
getConnectors
in interface BrokerFacade
null
Exception
public ConnectorViewFacade getConnector(String name) throws Exception
BrokerFacade
getConnector
in interface BrokerFacade
name
- name of the connector (f.e. openwire)null
if not foundException
public Collection<ConnectionViewFacade> getConnections() throws Exception
BrokerFacade
getConnections
in interface BrokerFacade
null
Exception
public Collection<String> getConnections(String connectorName) throws Exception
BrokerFacade
getConnections
in interface BrokerFacade
connectorName
- not null
null
Exception
BrokerFacade.getConnection(String)
public ConnectionViewFacade getConnection(String connectionName) throws Exception
BrokerFacade
getConnection
in interface BrokerFacade
connectionName
- the name of the connection, not null
null
Exception
public Collection<SubscriptionViewFacade> getConsumersOnConnection(String connectionName) throws Exception
BrokerFacade
getConsumersOnConnection
in interface BrokerFacade
connectionName
- the name of the connection, not null
null
Exception
public Collection<NetworkConnectorViewFacade> getNetworkConnectors() throws Exception
BrokerFacade
getNetworkConnectors
in interface BrokerFacade
null
Exception
public Collection<NetworkBridgeViewFacade> getNetworkBridges() throws Exception
BrokerFacade
getNetworkBridges
in interface BrokerFacade
null
Exception
public void purgeQueue(org.apache.activemq.command.ActiveMQDestination destination) throws Exception
BrokerFacade
purgeQueue
in interface BrokerFacade
Exception
public QueueViewFacade getQueue(String name) throws Exception
BrokerFacade
getQueue
in interface BrokerFacade
name
- not null
null
if no queue with this name existsException
public TopicViewFacade getTopic(String name) throws Exception
BrokerFacade
getTopic
in interface BrokerFacade
name
- not null
null
if no topic with this name existsException
public JobSchedulerViewFacade getJobScheduler() throws Exception
BrokerFacade
getJobScheduler
in interface BrokerFacade
Exception
public Collection<JobFacade> getScheduledJobs() throws Exception
BrokerFacade
getScheduledJobs
in interface BrokerFacade
Exception
public boolean isJobSchedulerStarted()
isJobSchedulerStarted
in interface BrokerFacade
Copyright © 2011–2014 Red Hat. All rights reserved.