Package org.apache.activemq.artemis.core.server.cluster

Interface ClusterConnection

All Superinterfaces:
ActiveMQComponent, ClusterTopologyListener
All Known Implementing Classes:
ClusterConnectionImpl
public interface ClusterConnection extends ActiveMQComponent, ClusterTopologyListener

  • Method Details

    • getName

      SimpleString getName()

    • getNodeID

      String getNodeID()

    • getServer

      ActiveMQServer getServer()

    • nodeAnnounced

      void nodeAnnounced(long eventUID, String nodeID, String backupGroupName, String scaleDownGroupName, Pair<TransportConfiguration,TransportConfiguration> connectorPair, boolean backup)

    • addClusterTopologyListener

      void addClusterTopologyListener(ClusterTopologyListener listener)

    • removeClusterTopologyListener

      void removeClusterTopologyListener(ClusterTopologyListener listener)

    • setSplitBrainDetection

      void setSplitBrainDetection(boolean splitBrainDetection)
      This is needed on replication, however we don't need it on shared storage.

    • isSplitBrainDetection

      boolean isSplitBrainDetection()

    • getNodes

      Map<String,String> getNodes()
      Only used for tests?
      Returns:
      a Map of node ID and addresses

    • getConnector

      TransportConfiguration getConnector()

    • getTopology

      Topology getTopology()

    • flushExecutor

      void flushExecutor()

    • describe

      String describe()

    • informClusterOfBackup

      void informClusterOfBackup()

    • isNodeActive

      boolean isNodeActive(String id)

    • verify

      boolean verify(String clusterUser, String clusterPassword)
      Verifies whether user and password match the ones configured for this ClusterConnection.
      Returns:
      true if username and password match, false otherwise

    • removeRecord

      void removeRecord(String targetNodeID)

    • disconnectRecord

      void disconnectRecord(String targetNodeID)

    • getCallTimeout

      long getCallTimeout()

    • getProducerWindowSize

      long getProducerWindowSize()

    • getBridges

      Bridge[] getBridges()

    • getMetrics

      ClusterConnectionMetrics getMetrics()
      The metric for this cluster connection

    • getBridgeMetrics

      BridgeMetrics getBridgeMetrics(String nodeId)
      Returns the BridgeMetrics for the bridge to the given node if exists.
      Returns:
      the BridgeMetrics for the bridge to the given node if exists