public class RemoteJMXBrokerFacade extends BrokerFacadeSupport
BrokerFacade
which uses a JMX-Connection to communicate with a
brokerConstructor and Description |
---|
RemoteJMXBrokerFacade() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConnection() |
protected JMXConnector |
createConnection() |
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.
|
org.apache.activemq.broker.jmx.BrokerViewMBean |
getBrokerAdmin()
Admin view of the broker.
|
String |
getBrokerName()
The name of the active broker (f.e.
|
WebConsoleConfiguration |
getConfiguration() |
protected <T> Collection<T> |
getManagedObjects(ObjectName[] names,
Class<T> type) |
org.apache.activemq.broker.jmx.ManagementContext |
getManagementContext() |
protected 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) |
void |
setConfiguration(WebConsoleConfiguration configuration) |
void |
shutdown()
Shutdown this facade aka close any open connection.
|
getConnection, getConnections, getConnections, getConnector, getConnectors, getConsumersOnConnection, getDestinationByName, getDurableTopicSubscribers, getInactiveDurableTopicSubscribers, getJobScheduler, getNetworkBridges, getNetworkConnectors, getNonDurableTopicSubscribers, getQueue, getQueueConsumers, getQueueProducers, getQueues, getScheduledJobs, getTopic, getTopicProducers, getTopics, getTopicSubscribers, isJobSchedulerStarted
public RemoteJMXBrokerFacade()
public void setBrokerName(String brokerName)
public WebConsoleConfiguration getConfiguration()
public void setConfiguration(WebConsoleConfiguration configuration)
public void shutdown()
public org.apache.activemq.broker.jmx.BrokerViewMBean getBrokerAdmin() throws Exception
BrokerFacade
null
Exception
public String getBrokerName() throws Exception, MalformedObjectNameException
BrokerFacade
null
Exception
MalformedObjectNameException
protected MBeanServerConnection getMBeanServerConnection() throws Exception
Exception
protected boolean isConnectionActive(JMXConnector connector)
protected JMXConnector createConnection()
protected void closeConnection()
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)
getManagedObjects
in class BrokerFacadeSupport
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
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.