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 Details

    • 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()
      Checks if the cluster has members.
      Returns:
      true if the cluster has members.

    • getMembers

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

    • getLocalMember

      Member getLocalMember()
      Returns the member that represents this node.
      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.
      Returns:
      the current Deployer

    • getManagers

      Map<String, ClusterManager> getManagers()
      Returns the map of managers.
      Returns:
      The map of managers

    • getManager

      Manager getManager(String name)
      Get Manager
      Parameters:
      name - The manager name
      Returns:
      The manager

    • getManagerName

      String getManagerName(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.
      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.
      Returns:
      the channel associated with the cluster