1 /*** 2 * 3 * Copyright 2004 Protique Ltd 4 * 5 * Licensed under the Apache License, Version 2.0 (the "License"); 6 * you may not use this file except in compliance with the License. 7 * You may obtain a copy of the License at 8 * 9 * http://www.apache.org/licenses/LICENSE-2.0 10 * 11 * Unless required by applicable law or agreed to in writing, software 12 * distributed under the License is distributed on an "AS IS" BASIS, 13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14 * See the License for the specific language governing permissions and 15 * limitations under the License. 16 * 17 **/ 18 package org.codehaus.activecluster; 19 20 import org.codehaus.activecluster.impl.DefaultCluster; 21 22 /*** 23 * @version $Revision: 1.2 $ 24 */ 25 public class TestingClusterListener implements ClusterListener { 26 private Cluster cluster; 27 28 public TestingClusterListener(Cluster cluster){ 29 this.cluster = cluster; 30 } 31 public void onNodeAdd(ClusterEvent event) { 32 printEvent("ADDED: ", event); 33 } 34 35 public void onNodeUpdate(ClusterEvent event) { 36 printEvent("UPDATED: ", event); 37 } 38 39 public void onNodeRemoved(ClusterEvent event) { 40 printEvent("REMOVED: ", event); 41 } 42 43 public void onNodeFailed(ClusterEvent event) { 44 printEvent("FAILED: ", event); 45 } 46 47 public void onCoordinatorChanged(ClusterEvent event) { 48 printEvent("COORDINATOR: ", event); 49 } 50 51 protected void printEvent(String text, ClusterEvent event) { 52 System.out.println(text + event.getNode()); 53 System.out.println("Current cluster is now: " + cluster.getNodes().keySet()); 54 } 55 }