public abstract class RemoteBrokerFacadeSupport extends BrokerFacadeSupport
Constructor and Description |
---|
RemoteBrokerFacadeSupport() |
RemoteBrokerFacadeSupport(java.lang.String brokerName) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Set<javax.management.ObjectName> |
findBrokers(javax.management.MBeanServerConnection connection)
Finds all ActiveMQ-Brokers registered on a certain JMX-Server or, if a
JMX-BrokerName has been set, the broker with that name.
|
BrokerViewFacade |
getBrokerAdmin()
Admin view of the broker.
|
java.lang.String |
getBrokerName()
The name of the active broker (f.e.
|
java.lang.String[] |
getBrokerNames() |
java.lang.String |
getId() |
protected <T> java.util.Collection<T> |
getManagedObjects(javax.management.ObjectName[] names,
java.lang.Class<T> type) |
org.apache.activemq.broker.jmx.ManagementContext |
getManagementContext() |
protected abstract javax.management.MBeanServerConnection |
getMBeanServerConnection() |
protected boolean |
isConnectionActive(javax.management.remote.JMXConnector connector) |
java.lang.Object |
newProxyInstance(javax.management.ObjectName objectName,
java.lang.Class interfaceClass,
boolean notificationBroadcaster) |
void |
purgeQueue(org.apache.activemq.command.ActiveMQDestination destination)
Purges the given destination
|
java.util.Set |
queryNames(javax.management.ObjectName name,
javax.management.QueryExp query) |
void |
setBrokerName(java.lang.String brokerName) |
getConnection, getConnections, getConnections, getConnector, getConnectors, getConsumersOnConnection, getDestinationByName, getDurableTopicSubscribers, getInactiveDurableTopicSubscribers, getJobScheduler, getManagedObjects, getNetworkBridges, getNetworkConnectors, getQueue, getQueueConsumers, getQueueProducers, getQueues, getScheduledJobs, getTopic, getTopicConsumers, getTopicDurableConsumers, getTopicProducers, getTopics, isJobSchedulerStarted, proxy
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getBrokers
public RemoteBrokerFacadeSupport()
public RemoteBrokerFacadeSupport(java.lang.String brokerName)
public java.lang.String getBrokerName() throws java.lang.Exception, javax.management.MalformedObjectNameException
BrokerFacade
null
java.lang.Exception
javax.management.MalformedObjectNameException
public void setBrokerName(java.lang.String brokerName)
public BrokerViewFacade getBrokerAdmin() throws java.lang.Exception
BrokerFacade
null
java.lang.Exception
public java.lang.String getId() throws java.lang.Exception
java.lang.Exception
public java.lang.String[] getBrokerNames() throws java.lang.Exception
java.lang.Exception
protected abstract javax.management.MBeanServerConnection getMBeanServerConnection() throws java.lang.Exception
java.lang.Exception
protected java.util.Set<javax.management.ObjectName> findBrokers(javax.management.MBeanServerConnection connection) throws java.io.IOException, javax.management.MalformedObjectNameException
connection
- not null
java.io.IOException
javax.management.MalformedObjectNameException
public void purgeQueue(org.apache.activemq.command.ActiveMQDestination destination) throws java.lang.Exception
BrokerFacade
java.lang.Exception
public org.apache.activemq.broker.jmx.ManagementContext getManagementContext()
getManagementContext
in class BrokerFacadeSupport
protected <T> java.util.Collection<T> getManagedObjects(javax.management.ObjectName[] names, java.lang.Class<T> type)
public java.util.Set queryNames(javax.management.ObjectName name, javax.management.QueryExp query) throws java.lang.Exception
queryNames
in class BrokerFacadeSupport
java.lang.Exception
public java.lang.Object newProxyInstance(javax.management.ObjectName objectName, java.lang.Class interfaceClass, boolean notificationBroadcaster) throws java.lang.Exception
newProxyInstance
in class BrokerFacadeSupport
java.lang.Exception
protected boolean isConnectionActive(javax.management.remote.JMXConnector connector)
Copyright © 2017 Red Hat. All Rights Reserved.