org.hornetq.core.management.impl

Class ClusterConnectionControlImpl

java.lang.Object

javax.management.StandardMBean

org.hornetq.core.management.impl.AbstractControl

org.hornetq.core.management.impl.ClusterConnectionControlImpl

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, ClusterConnectionControl, HornetQComponentControl

public class ClusterConnectionControlImpl
extends AbstractControl
implements ClusterConnectionControl

A ClusterConnectionControl

Author:

Jeff Mesnil

Field Summary

Fields inherited from class org.hornetq.core.management.impl.AbstractControl

storageManager

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String	getAddress() Returns the address used by this cluster connection.
String	getDiscoveryGroupName() Returns the name of the discovery group used by this cluster connection.
int	getMaxHops() Returns the maximum number of hops used by this cluster connection.
String	getName() Returns the configuration name of this cluster connection.
String	getNodeID() Returns the node ID used by this cluster connection.
Map<String,String>	getNodes() Returns a map of the nodes connected to this cluster connection.
long	getRetryInterval() Returns the connection retry interval used by this cluster connection.
String[]	getStaticConnectors() Returns the list of static connectors
String	getStaticConnectorsAsJSON() Returns the list of static connectors as JSON
String	getTopology() Return the Topology that this Cluster Connection knows about
boolean	isDuplicateDetection() Return whether this cluster connection use duplicate detection.
boolean	isForwardWhenNoConsumers() Return whether this cluster connection forward messages when it has no local consumers.
boolean	isStarted() Returns true if this component is started, false else.
void	start() Starts this component.
void	stop() Stops this component.

Methods inherited from class org.hornetq.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()

Description copied from interface: ClusterConnectionControl

Returns the address used by this cluster connection.

Specified by:

getAddress in interface ClusterConnectionControl

getDiscoveryGroupName

public String getDiscoveryGroupName()

Description copied from interface: ClusterConnectionControl

Returns the name of the discovery group used by this cluster connection.

Specified by:

getDiscoveryGroupName in interface ClusterConnectionControl

getMaxHops

public int getMaxHops()

Description copied from interface: ClusterConnectionControl

Returns the maximum number of hops used by this cluster connection.

Specified by:

getMaxHops in interface ClusterConnectionControl

getName

public String getName()

Description copied from interface: ClusterConnectionControl

Returns the configuration name of this cluster connection.

Specified by:

getName in interface ClusterConnectionControl

getRetryInterval

public long getRetryInterval()

Description copied from interface: ClusterConnectionControl

Returns the connection retry interval used by this cluster connection.

Specified by:

getRetryInterval in interface ClusterConnectionControl

getNodeID

public String getNodeID()

Description copied from interface: ClusterConnectionControl

Returns the node ID used by this cluster connection.

Specified by:

getNodeID in interface ClusterConnectionControl

getStaticConnectors

public String[] getStaticConnectors()

Description copied from interface: ClusterConnectionControl

Returns the list of static connectors

Specified by:

getStaticConnectors in interface ClusterConnectionControl

getStaticConnectorsAsJSON

public String getStaticConnectorsAsJSON()
                                 throws Exception

Description copied from interface: ClusterConnectionControl

Returns the list of static connectors as JSON

Specified by:

getStaticConnectorsAsJSON in interface ClusterConnectionControl

Throws:

Exception

isDuplicateDetection

public boolean isDuplicateDetection()

Description copied from interface: ClusterConnectionControl

Return whether this cluster connection use duplicate detection.

Specified by:

isDuplicateDetection in interface ClusterConnectionControl

isForwardWhenNoConsumers

public boolean isForwardWhenNoConsumers()

Description copied from interface: ClusterConnectionControl

Return whether this cluster connection forward messages when it has no local consumers.

Specified by:

isForwardWhenNoConsumers in interface ClusterConnectionControl

getTopology

public String getTopology()

Description copied from interface: ClusterConnectionControl

Return the Topology that this Cluster Connection knows about

Specified by:

getTopology in interface ClusterConnectionControl

getNodes

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

Description copied from interface: ClusterConnectionControl

Returns a map of the nodes connected to this cluster connection.
keys are node IDs, values are the addresses used to connect to the nodes.

Specified by:

getNodes in interface ClusterConnectionControl

Throws:

Exception

isStarted

public boolean isStarted()

Description copied from interface: HornetQComponentControl

Returns true if this component is started, false else.

Specified by:

isStarted in interface HornetQComponentControl

start

public void start()
           throws Exception

Description copied from interface: HornetQComponentControl

Starts this component.

Specified by:

start in interface HornetQComponentControl

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: HornetQComponentControl

Stops this component.

Specified by:

stop in interface HornetQComponentControl

Throws:

Exception

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class AbstractControl