Package org.apache.catalina.ha

Interface CatalinaCluster

  • All Superinterfaces:
    Cluster, Contained
    All Known Implementing Classes:
    SimpleTcpCluster
    public interface CatalinaCluster
extends Cluster
    A CatalinaCluster interface allows to plug in and out the different cluster implementations

    • Method Detail

      • send

        void send​(ClusterMessage msg)
        Sends a message to all the members in the cluster
        Parameters:
        msg - ClusterMessage

      • send

        void send​(ClusterMessage msg,
          Member dest)
        Sends a message to a specific member in the cluster.
        Parameters:
        msg - ClusterMessage
        dest - Member

      • send

        void send​(ClusterMessage msg,
          Member dest,
          int sendOptions)
        Sends a message with the specified sendOptions to a specific member in the cluster.
        Parameters:
        msg - ClusterMessage
        dest - Member
        sendOptions - sendOptions

      • hasMembers

        boolean hasMembers()
        Returns:
        true if the cluster has members.

      • getMembers

        Member[] getMembers()
        Returns:
        an array containing all the members currently participating in the cluster.

      • getLocalMember

        Member getLocalMember()
        Returns:
        the member that represents this node.

      • addValve

        void addValve​(Valve valve)
        Add cluster valve. Cluster Valves are only add to container when cluster is started.
        Parameters:
        valve - The new cluster Valve.

      • addClusterListener

        void addClusterListener​(ClusterListener listener)
        Add cluster message listener and register cluster to this listener.
        Parameters:
        listener - The new listener

      • removeClusterListener

        void removeClusterListener​(ClusterListener listener)
        Remove message listener and deregister Cluster from listener.
        Parameters:
        listener - The listener to remove

      • setClusterDeployer

        void setClusterDeployer​(ClusterDeployer deployer)
        Set a new Deployer, must be set before the cluster started.
        Parameters:
        deployer - The associated deployer

      • getClusterDeployer

        ClusterDeployer getClusterDeployer()
        Returns:
        the current Deployer

      • getManagers

        java.util.Map<java.lang.String,​ClusterManager> getManagers()
        Returns:
        The map of managers

      • getManager

        Manager getManager​(java.lang.String name)
        Get Manager
        Parameters:
        name - The manager name
        Returns:
        The manager

      • getManagerName

        java.lang.String getManagerName​(java.lang.String name,
                                Manager manager)
        Get a new cluster name for a manager.
        Parameters:
        name - Override name (optional)
        manager - The manager
        Returns:
        the manager name in the cluster

      • getValves

        Valve[] getValves()
        Returns:
        the current cluster valves

      • setChannel

        void setChannel​(Channel channel)
        Set the channel associated with the cluster.
        Parameters:
        channel - the channel

      • getChannel

        Channel getChannel()
        Returns:
        the channel associated with the cluster