Examples of ClusterListener

org.apache.catalina.ha.ClusterListener
Receive SessionID cluster change from other backup node after primary session node is failed. @author Peter Rossbach @author Filip Hanik @version $Revision: 378258 $ $Date: 2006-02-16 08:42:35 -0600 (Thu, 16 Feb 2006) $
org.codehaus.activecluster.ClusterListener
Listener to events occuring on the cluster @version $Revision: 1.3 $
org.prevayler.cluster.ClusterListener
sos.scheduler.editor.conf.listeners.ClusterListener

Examples of org.apache.catalina.ha.ClusterListener


        //invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator iter = clusterListeners.iterator(); iter.hasNext();) {
                ClusterListener listener = (ClusterListener) iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
        }
        if (!accepted && log.isDebugEnabled()) {
            if (notifyLifecycleListenerOnFailure) {

View Full Code Here

Examples of org.apache.catalina.ha.ClusterListener

        //invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator<ClusterListener> iter = clusterListeners.iterator();
                    iter.hasNext();) {
                ClusterListener listener = iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
            if (!accepted && notifyLifecycleListenerOnFailure) {
                Member dest = message.getAddress();
                // Notify our interested LifecycleListeners

View Full Code Here

Examples of org.apache.catalina.ha.ClusterListener

        //invoke all the listeners
        boolean accepted = false;
        if (message != null) {
            for (Iterator<ClusterListener> iter = clusterListeners.iterator();
                    iter.hasNext();) {
                ClusterListener listener = iter.next();
                if (listener.accept(message)) {
                    accepted = true;
                    listener.messageReceived(message);
                }
            }
            if (!accepted && notifyLifecycleListenerOnFailure) {
                Member dest = message.getAddress();
                // Notify our interested LifecycleListeners

View Full Code Here

Examples of org.codehaus.activecluster.ClusterListener


        ClusterEvent event = new ClusterEvent(cluster, node, ClusterEvent.ADD_NODE);
        // lets take a copy to make contention easier
        Object[] array = listeners.toArray();
        for (int i = 0, size = array.length; i < size; i++) {
            ClusterListener listener = (ClusterListener) array[i];
            listener.onNodeRemoved(event);
        }
    }

View Full Code Here

Examples of org.codehaus.activecluster.ClusterListener

    protected void nodeAdded(Node node) {
        ClusterEvent event = new ClusterEvent(cluster, node, ClusterEvent.ADD_NODE);
        // lets take a copy to make contention easier
        Object[] array = listeners.toArray();
        for (int i = 0, size = array.length; i < size; i++) {
            ClusterListener listener = (ClusterListener) array[i];
            listener.onNodeAdd(event);
        }
        doElection();
    }

View Full Code Here

Examples of org.codehaus.activecluster.ClusterListener

    protected void nodeUpdated(Node node) {
        ClusterEvent event = new ClusterEvent(cluster, node, ClusterEvent.UPDATE_NODE);
        // lets take a copy to make contention easier
        Object[] array = listeners.toArray();
        for (int i = 0, size = array.length; i < size; i++) {
            ClusterListener listener = (ClusterListener) array[i];
            listener.onNodeUpdate(event);
        }
    }

View Full Code Here

Examples of org.codehaus.activecluster.ClusterListener

    protected void nodeFailed(Node node) {
        ClusterEvent event = new ClusterEvent(cluster, node, ClusterEvent.REMOVE_NODE);
        // lets take a copy to make contention easier
        Object[] array = listeners.toArray();
        for (int i = 0, size = array.length; i < size; i++) {
            ClusterListener listener = (ClusterListener) array[i];
            listener.onNodeFailed(event);
        }
        doElection();
    }

View Full Code Here

Examples of org.codehaus.activecluster.ClusterListener

    protected void coordinatorChanged(Node node) {
        ClusterEvent event = new ClusterEvent(cluster, node, ClusterEvent.ELECTED_COORDINATOR);
        // lets take a copy to make contention easier
        Object[] array = listeners.toArray();
        for (int i = 0, size = array.length; i < size; i++) {
            ClusterListener listener = (ClusterListener) array[i];
            listener.onCoordinatorChanged(event);
        }
    }

View Full Code Here

Examples of org.prevayler.cluster.ClusterListener

      assertEquals(new Integer(i), receivedMessages.get(i));
    }
  }


  private ClusterListener createListAddListener() {
    return new ClusterListener() {
      public Object receive(Object message) {
        receivedMessages.add(message);
        return null;
      }

View Full Code Here

Examples of sos.scheduler.editor.conf.listeners.ClusterListener

  }




  public void setAttributes(SchedulerDom dom, Element element, int type) {


    listener = new ClusterListener(dom, element);
    tOwnTimeout.setText(listener.getHeartbeatOwnTimeout());
    tWarnTimeout.setText(listener.getHeartbeatWarnTimeout());
    tTimeout.setText(listener.getHeartbeatTimeout());


  }

View Full Code Here

0 1 2 3 4

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.