public abstract class RemoteBrokerFacadeSupport extends BrokerFacadeSupport
Constructor and Description |
---|
RemoteBrokerFacadeSupport() |
RemoteBrokerFacadeSupport(String brokerName) |
Modifier and Type | Method and Description |
---|---|
protected Set<ObjectName> |
findBrokers(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.
|
String |
getBrokerName()
The name of the active broker (f.e.
|
String[] |
getBrokerNames() |
String |
getId() |
protected <T> Collection<T> |
getManagedObjects(ObjectName[] names,
Class<T> type) |
org.apache.activemq.broker.jmx.ManagementContext |
getManagementContext() |
protected abstract MBeanServerConnection |
getMBeanServerConnection() |
protected boolean |
isConnectionActive(JMXConnector connector) |
Object |
newProxyInstance(ObjectName objectName,
Class interfaceClass,
boolean notificationBroadcaster) |
void |
purgeQueue(org.apache.activemq.command.ActiveMQDestination destination)
Purges the given destination
|
Set |
queryNames(ObjectName name,
QueryExp query) |
void |
setBrokerName(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(String brokerName)
public String getBrokerName() throws Exception, MalformedObjectNameException
BrokerFacade
null
Exception
MalformedObjectNameException
public void setBrokerName(String brokerName)
public BrokerViewFacade getBrokerAdmin() throws Exception
BrokerFacade
null
Exception
public String getId() throws Exception
Exception
protected abstract MBeanServerConnection getMBeanServerConnection() throws Exception
Exception
protected Set<ObjectName> findBrokers(MBeanServerConnection connection) throws IOException, MalformedObjectNameException
connection
- not null
IOException
MalformedObjectNameException
public void purgeQueue(org.apache.activemq.command.ActiveMQDestination destination) throws Exception
BrokerFacade
Exception
public org.apache.activemq.broker.jmx.ManagementContext getManagementContext()
getManagementContext
in class BrokerFacadeSupport
protected <T> Collection<T> getManagedObjects(ObjectName[] names, Class<T> type)
public Set queryNames(ObjectName name, QueryExp query) throws Exception
queryNames
in class BrokerFacadeSupport
Exception
public Object newProxyInstance(ObjectName objectName, Class interfaceClass, boolean notificationBroadcaster) throws Exception
newProxyInstance
in class BrokerFacadeSupport
Exception
protected boolean isConnectionActive(JMXConnector connector)
Copyright © 2011–2014 Red Hat. All rights reserved.