Class ClusterConnectionControlImpl
- All Implemented Interfaces:
DynamicMBean,MBeanRegistration,ActiveMQComponentControl,ClusterConnectionControl
-
Field Summary
Fields inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl
storageManager -
Constructor Summary
ConstructorsConstructorDescriptionClusterConnectionControlImpl(ClusterConnection clusterConnection, StorageManager storageManager, ClusterConnectionConfiguration configuration) -
Method Summary
Modifier and TypeMethodDescriptionprotected MBeanAttributeInfo[]protected MBeanOperationInfo[]Returns the address used by this cluster connection.getBridgeMetrics(String nodeId) The bridge metrics for the given node in the cluster connectionReturns the name of the discovery group used by this cluster connection.intReturns the maximum number of hops used by this cluster connection.Returns the type of message load balancing strategy this bridge will use.longThe messagesAcknowledged counter is the number of messages actually received by a remote broker for all bridges in this cluster connectionlongThe messagesPendingAcknowledgement counter is incremented when any bridge in the cluster connection has forwarded a message and is waiting acknowledgement from the other broker.The current metrics for this cluster connection (aggregate over all bridges to other nodes)getName()Returns the configuration name of this cluster connection.Returns the node ID used by this cluster connection.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.longlongReturns the connection retry interval used by this cluster connection.String[]Returns the list of static connectors.Returns the list of static connectors as JSON.Returns the Topology that this Cluster Connection knows about.booleanReturns whether this cluster connection use duplicate detection.booleanReturnstrueif this component is started,falseelse..voidstart()Starts this component.voidstop()Stops this component.Methods inherited from class org.apache.activemq.artemis.core.management.impl.AbstractControl
blockOnIO, clearIO, getMBeanInfo, sendMessage, tcclCall, tcclInvokeMethods 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
-
Constructor Details
-
ClusterConnectionControlImpl
public ClusterConnectionControlImpl(ClusterConnection clusterConnection, StorageManager storageManager, ClusterConnectionConfiguration configuration) throws Exception - Throws:
Exception
-
-
Method Details
-
getAddress
Description copied from interface:ClusterConnectionControlReturns the address used by this cluster connection.- Specified by:
getAddressin interfaceClusterConnectionControl- Returns:
- the address used by this cluster connection
-
getDiscoveryGroupName
Description copied from interface:ClusterConnectionControlReturns the name of the discovery group used by this cluster connection.- Specified by:
getDiscoveryGroupNamein interfaceClusterConnectionControl- Returns:
- the name of the discovery group used by this cluster connection
-
getMaxHops
public int getMaxHops()Description copied from interface:ClusterConnectionControlReturns the maximum number of hops used by this cluster connection.- Specified by:
getMaxHopsin interfaceClusterConnectionControl- Returns:
- the maximum number of hops used by this cluster connection
-
getName
Description copied from interface:ClusterConnectionControlReturns the configuration name of this cluster connection.- Specified by:
getNamein interfaceClusterConnectionControl- Returns:
- the configuration name of this cluster connection
-
getRetryInterval
public long getRetryInterval()Description copied from interface:ClusterConnectionControlReturns the connection retry interval used by this cluster connection.- Specified by:
getRetryIntervalin interfaceClusterConnectionControl- Returns:
- the connection retry interval used by this cluster connection
-
getNodeID
Description copied from interface:ClusterConnectionControlReturns the node ID used by this cluster connection.- Specified by:
getNodeIDin interfaceClusterConnectionControl- Returns:
- the node ID used by this cluster connection
-
getStaticConnectors
Description copied from interface:ClusterConnectionControlReturns the list of static connectors.- Specified by:
getStaticConnectorsin interfaceClusterConnectionControl- Returns:
- the list of static connectors
-
getStaticConnectorsAsJSON
Description copied from interface:ClusterConnectionControlReturns the list of static connectors as JSON.- Specified by:
getStaticConnectorsAsJSONin interfaceClusterConnectionControl- Returns:
- the list of static connectors as JSON
- Throws:
Exception
-
isDuplicateDetection
public boolean isDuplicateDetection()Description copied from interface:ClusterConnectionControlReturns whether this cluster connection use duplicate detection.- Specified by:
isDuplicateDetectionin interfaceClusterConnectionControl- Returns:
- whether this cluster connection use duplicate detection
-
getMessageLoadBalancingType
Description copied from interface:ClusterConnectionControlReturns the type of message load balancing strategy this bridge will use.- Specified by:
getMessageLoadBalancingTypein interfaceClusterConnectionControl- Returns:
- the type of message load balancing strategy this bridge will use
-
getTopology
Description copied from interface:ClusterConnectionControlReturns the Topology that this Cluster Connection knows about.- Specified by:
getTopologyin interfaceClusterConnectionControl- Returns:
- the Topology that this Cluster Connection knows about
-
getNodes
Description copied from interface:ClusterConnectionControlReturns 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:
getNodesin interfaceClusterConnectionControl- 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:ActiveMQComponentControlReturnstrueif this component is started,falseelse..- Specified by:
isStartedin interfaceActiveMQComponentControl- Returns:
trueif this component is started,falseelse.
-
start
Description copied from interface:ActiveMQComponentControlStarts this component.- Specified by:
startin interfaceActiveMQComponentControl- Throws:
Exception
-
stop
Description copied from interface:ActiveMQComponentControlStops this component.- Specified by:
stopin interfaceActiveMQComponentControl- Throws:
Exception
-
fillMBeanOperationInfo
- Specified by:
fillMBeanOperationInfoin classAbstractControl
-
fillMBeanAttributeInfo
- Specified by:
fillMBeanAttributeInfoin classAbstractControl
-
getMessagesPendingAcknowledgement
public long getMessagesPendingAcknowledgement()Description copied from interface:ClusterConnectionControlThe 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:
getMessagesPendingAcknowledgementin interfaceClusterConnectionControl
-
getMessagesAcknowledged
public long getMessagesAcknowledged()Description copied from interface:ClusterConnectionControlThe messagesAcknowledged counter is the number of messages actually received by a remote broker for all bridges in this cluster connectionThis 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:
getMessagesAcknowledgedin interfaceClusterConnectionControl
-
getMetrics
Description copied from interface:ClusterConnectionControlThe 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:
getMetricsin interfaceClusterConnectionControl
-
getBridgeMetrics
Description copied from interface:ClusterConnectionControlThe bridge metrics for the given node in the cluster connectionThe 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:
getBridgeMetricsin interfaceClusterConnectionControl
-
getProducerWindowSize
public long getProducerWindowSize()- Specified by:
getProducerWindowSizein interfaceClusterConnectionControl
-