Interface ClusterConnectionControl

All Superinterfaces:
ActiveMQComponentControl

public interface ClusterConnectionControl extends ActiveMQComponentControl
A ClusterConnectionControl is used to manage a cluster connection.
  • Method Summary

    Modifier and Type
    Method
    Description
    Returns the address used by this cluster connection.
    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.
    Returns the name of the discovery group used by this cluster connection.
    int
    Returns the maximum number of hops used by this cluster connection.
    Return the type of message load balancing strategy this bridge will use.
    long
    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.
    long
    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 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.
    Returns the configuration name of this cluster connection.
    Returns the node ID used by this cluster connection.
    Returns a map of the nodes connected to this cluster connection.
    long
     
    long
    Returns the connection retry interval used by this cluster connection.
    Returns the list of static connectors
    Returns the list of static connectors as JSON
    Return the Topology that this Cluster Connection knows about
    boolean
    Return whether this cluster connection use duplicate detection.

    Methods inherited from interface org.apache.activemq.artemis.api.core.management.ActiveMQComponentControl

    isStarted, start, stop
  • Method Details

    • getName

      String getName()
      Returns the configuration name of this cluster connection.
    • getAddress

      String getAddress()
      Returns the address used by this cluster connection.
    • getNodeID

      String getNodeID()
      Returns the node ID used by this cluster connection.
    • isDuplicateDetection

      boolean isDuplicateDetection()
      Return whether this cluster connection use duplicate detection.
    • getMessageLoadBalancingType

      String getMessageLoadBalancingType()
      Return the type of message load balancing strategy this bridge will use.
    • getTopology

      String getTopology()
      Return the Topology that this Cluster Connection knows about
    • getMaxHops

      int getMaxHops()
      Returns the maximum number of hops used by this cluster connection.
    • getStaticConnectors

      Object[] getStaticConnectors()
      Returns the list of static connectors
    • getStaticConnectorsAsJSON

      String getStaticConnectorsAsJSON() throws Exception
      Returns the list of static connectors as JSON
      Throws:
      Exception
    • getDiscoveryGroupName

      String getDiscoveryGroupName()
      Returns the name of the discovery group used by this cluster connection.
    • getRetryInterval

      long getRetryInterval()
      Returns the connection retry interval used by this cluster connection.
    • getNodes

      Map<String,String> getNodes() throws Exception
      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
    • getMessagesPendingAcknowledgement

      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. (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.
    • getMessagesAcknowledged

      long getMessagesAcknowledged()
      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.
    • getMetrics

      Map<String,Object> getMetrics()
      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
      Returns:
    • getBridgeMetrics

      Map<String,Object> getBridgeMetrics(String nodeId) throws Exception
      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.
      Throws:
      Exception
    • getProducerWindowSize

      long getProducerWindowSize()