Package 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, ActiveMQComponentControl, ClusterConnectionControl

public class ClusterConnectionControlImpl
extends AbstractControl
implements ClusterConnectionControl

Field Summary

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

storageManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected MBeanAttributeInfo[]	fillMBeanAttributeInfo()
protected MBeanOperationInfo[]	fillMBeanOperationInfo()
String	getAddress()	Returns the address used by this cluster connection.
Map<String,Object>	getBridgeMetrics(String nodeId)	The bridge metrics for the given node in the 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	getMessageLoadBalancingType()	Returns the type of message load balancing strategy this bridge will use.
long	getMessagesAcknowledged()	The messagesAcknowledged counter is the number of messages actually received by a remote broker for all bridges in this cluster connection
long	getMessagesPendingAcknowledgement()	The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has forwarded a message and is waiting acknowledgement from the other broker.
Map<String,Object>	getMetrics()	The current metrics for this cluster connection (aggregate over all bridges to other nodes)
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; keys are node IDs, values are the addresses used to connect to the nodes.
long	getProducerWindowSize()
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()	Returns the Topology that this Cluster Connection knows about.
boolean	isDuplicateDetection()	Returns whether this cluster connection use duplicate detection.
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.apache.activemq.artemis.core.management.impl.AbstractControl

blockOnIO, clearIO, getMBeanInfo, sendMessage, tcclCall, tcclInvoke

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 Details

ClusterConnectionControlImpl

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

Throws:

Exception

Method Details

getAddress

public String getAddress()

Description copied from interface: ClusterConnectionControl

Returns the address used by this cluster connection.

Specified by:

getAddress in interface ClusterConnectionControl

Returns:

the address used by this cluster connection

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

Returns:

the name of the discovery group used by this cluster connection

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

Returns:

the maximum number of hops used by this cluster connection

getName

public String getName()

Description copied from interface: ClusterConnectionControl

Returns the configuration name of this cluster connection.

Specified by:

getName in interface ClusterConnectionControl

Returns:

the configuration name of this cluster connection

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

Returns:

the connection retry interval used by this cluster connection

getNodeID

public String getNodeID()

Description copied from interface: ClusterConnectionControl

Returns the node ID used by this cluster connection.

Specified by:

getNodeID in interface ClusterConnectionControl

Returns:

the node ID used by this cluster connection

getStaticConnectors

public String[] getStaticConnectors()

Description copied from interface: ClusterConnectionControl

Returns the list of static connectors.

Specified by:

getStaticConnectors in interface ClusterConnectionControl

Returns:

the list of static connectors

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

Returns:

the list of static connectors as JSON

Throws:

Exception

isDuplicateDetection

public boolean isDuplicateDetection()

Description copied from interface: ClusterConnectionControl

Returns whether this cluster connection use duplicate detection.

Specified by:

isDuplicateDetection in interface ClusterConnectionControl

Returns:

whether this cluster connection use duplicate detection

getMessageLoadBalancingType

public String getMessageLoadBalancingType()

Description copied from interface: ClusterConnectionControl

Returns the type of message load balancing strategy this bridge will use.

Specified by:

getMessageLoadBalancingType in interface ClusterConnectionControl

Returns:

the type of message load balancing strategy this bridge will use

getTopology

public String getTopology()

Description copied from interface: ClusterConnectionControl

Returns the Topology that this Cluster Connection knows about.

Specified by:

getTopology in interface ClusterConnectionControl

Returns:

the Topology that this Cluster Connection knows about

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

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

Throws:

Exception

isStarted

public boolean isStarted()

Description copied from interface: ActiveMQComponentControl

Returns true if this component is started, false else..

Specified by:

isStarted in interface ActiveMQComponentControl

Returns:

true if this component is started, false else.

start

public void start()
           throws Exception

Description copied from interface: ActiveMQComponentControl

Starts this component.

Specified by:

start in interface ActiveMQComponentControl

Throws:

Exception

stop

public void stop()
          throws Exception

Description copied from interface: ActiveMQComponentControl

Stops this component.

Specified by:

stop in interface ActiveMQComponentControl

Throws:

Exception

fillMBeanOperationInfo

protected MBeanOperationInfo[] fillMBeanOperationInfo()

Specified by:

fillMBeanOperationInfo in class AbstractControl

fillMBeanAttributeInfo

protected MBeanAttributeInfo[] fillMBeanAttributeInfo()

Specified by:

fillMBeanAttributeInfo in class AbstractControl

getMessagesPendingAcknowledgement

public long getMessagesPendingAcknowledgement()

Description copied from interface: ClusterConnectionControl

The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has forwarded a message and is waiting acknowledgement from the other broker. (aggregate over all bridges)

This is a cumulative total and the number of outstanding pending messages for the cluster connection can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.

Specified by:

getMessagesPendingAcknowledgement in interface ClusterConnectionControl

getMessagesAcknowledged

public long getMessagesAcknowledged()

Description copied from interface: ClusterConnectionControl

The messagesAcknowledged counter is the number of messages actually received by a remote broker for all bridges in this cluster connection

This is a cumulative total and the number of outstanding pending messages for the cluster connection can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.

Specified by:

getMessagesAcknowledged in interface ClusterConnectionControl

getMetrics

public Map<String,Object> getMetrics()

Description copied from interface: ClusterConnectionControl

The current metrics for this cluster connection (aggregate over all bridges to other nodes)

The messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has forwarded a message and is waiting acknowledgement from the other broker.

The messagesAcknowledged counter is the number of messages actually received by a remote broker for all bridges in this cluster connection

Specified by:

getMetrics in interface ClusterConnectionControl

getBridgeMetrics

public Map<String,Object> getBridgeMetrics(String nodeId)

Description copied from interface: ClusterConnectionControl

The bridge metrics for the given node in the cluster connection

The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker. The messagesAcknowledged counter is the number of messages actually received by the remote broker for this bridge.

Specified by:

getBridgeMetrics in interface ClusterConnectionControl

getProducerWindowSize

public long getProducerWindowSize()

Specified by:

getProducerWindowSize in interface ClusterConnectionControl