Package akka.cluster

Interface ClusterNodeMBean

  • public interface ClusterNodeMBean
    Member status for this node.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void down​(java.lang.String address)
      Send command to DOWN the node specified by 'address'.
      java.lang.String getClusterStatus()  
      java.lang.String getLeader()
      Get the address of the current leader.
      java.lang.String getMembers()
      Comma separated addresses of member nodes, sorted in the cluster ring order.
      java.lang.String getMemberStatus()  
      java.lang.String getUnreachable()
      Comma separated addresses of unreachable member nodes.
      boolean isAvailable()
      Returns true if the node is not unreachable and not Down and not Removed.
      boolean isSingleton()
      Does the cluster consist of only one member?
      void join​(java.lang.String address)
      Try to join this cluster node with the node specified by 'address'.
      void leave​(java.lang.String address)
      Send command to issue state transition to LEAVING for the node specified by 'address'.

    • Method Detail

      • down

        void down​(java.lang.String address)
        Send command to DOWN the node specified by 'address'. The address format is akka.tcp://actor-system-name@hostname:port
        Parameters:
        address - (undocumented)

      • getClusterStatus

        java.lang.String getClusterStatus()

      • getLeader

        java.lang.String getLeader()
        Get the address of the current leader. The address format is akka.tcp://actor-system-name@hostname:port
        Returns:
        (undocumented)

      • getMemberStatus

        java.lang.String getMemberStatus()

      • getMembers

        java.lang.String getMembers()
        Comma separated addresses of member nodes, sorted in the cluster ring order. The address format is akka.tcp://actor-system-name@hostname:port
        Returns:
        (undocumented)

      • getUnreachable

        java.lang.String getUnreachable()
        Comma separated addresses of unreachable member nodes. The address format is akka.tcp://actor-system-name@hostname:port
        Returns:
        (undocumented)

      • isAvailable

        boolean isAvailable()
        Returns true if the node is not unreachable and not Down and not Removed.
        Returns:
        (undocumented)

      • isSingleton

        boolean isSingleton()
        Does the cluster consist of only one member?
        Returns:
        (undocumented)

      • join

        void join​(java.lang.String address)
        Try to join this cluster node with the node specified by 'address'. The address format is akka.tcp://actor-system-name@hostname:port. A 'Join(thisNodeAddress)' command is sent to the node to join.
        Parameters:
        address - (undocumented)

      • leave

        void leave​(java.lang.String address)
        Send command to issue state transition to LEAVING for the node specified by 'address'. The address format is akka.tcp://actor-system-name@hostname:port
        Parameters:
        address - (undocumented)