org.apache.activemq.artemis.core.management.impl

Class ClusterConnectionControlImpl

java.lang.Object

javax.management.StandardMBean

org.apache.activemq.artemis.core.management.impl.AbstractControl

org.apache.activemq.artemis.core.management.impl.ClusterConnectionControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, org.apache.activemq.artemis.api.core.management.ActiveMQComponentControl, org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

public class ClusterConnectionControlImpl
extends AbstractControl
implements org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl

storageManager

Constructor Summary

Constructors

Constructor and Description
ClusterConnectionControlImpl(ClusterConnection clusterConnection, StorageManager storageManager, ClusterConnectionConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
protected MBeanAttributeInfo[]	fillMBeanAttributeInfo()
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String	getAddress()
String	getDiscoveryGroupName()
int	getMaxHops()
String	getMessageLoadBalancingType()
String	getName()
String	getNodeID()
Map<String,String>	getNodes()
long	getRetryInterval()
String[]	getStaticConnectors()
String	getStaticConnectorsAsJSON()
String	getTopology()
boolean	isDuplicateDetection()
boolean	isStarted()
void	start()
void	stop()

Methods inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl

blockOnIO, clearIO, getMBeanInfo

Methods inherited from class javax.management.StandardMBean

cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterConnectionControlImpl

public ClusterConnectionControlImpl(ClusterConnection clusterConnection,
                                    StorageManager storageManager,
                                    ClusterConnectionConfiguration configuration)
                             throws Exception

Throws:

Exception

Method Detail

getAddress

public String getAddress()

Specified by:

getAddress in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getDiscoveryGroupName

public String getDiscoveryGroupName()

Specified by:

getDiscoveryGroupName in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getMaxHops

public int getMaxHops()

Specified by:

getMaxHops in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getName

public String getName()

Specified by:

getName in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getRetryInterval

public long getRetryInterval()

Specified by:

getRetryInterval in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getNodeID

public String getNodeID()

Specified by:

getNodeID in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getStaticConnectors

public String[] getStaticConnectors()

Specified by:

getStaticConnectors in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getStaticConnectorsAsJSON

public String getStaticConnectorsAsJSON()
                                 throws Exception

Specified by:

getStaticConnectorsAsJSON in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

Throws:

Exception

isDuplicateDetection

public boolean isDuplicateDetection()

Specified by:

isDuplicateDetection in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getMessageLoadBalancingType

public String getMessageLoadBalancingType()

Specified by:

getMessageLoadBalancingType in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getTopology

public String getTopology()

Specified by:

getTopology in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

getNodes

public Map<String,String> getNodes()
                            throws Exception

Specified by:

getNodes in interface org.apache.activemq.artemis.api.core.management.ClusterConnectionControl

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface org.apache.activemq.artemis.api.core.management.ActiveMQComponentControl

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.artemis.api.core.management.ActiveMQComponentControl

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.artemis.api.core.management.ActiveMQComponentControl

Throws:

Exception

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class AbstractControl

fillMBeanAttributeInfo

protected MBeanAttributeInfo[] fillMBeanAttributeInfo()

Specified by:

fillMBeanAttributeInfo in class AbstractControl