1 24 25 package org.objectweb.dream.protocol.utobcast; 26 27 import org.objectweb.dream.AbstractComponent; 28 import org.objectweb.dream.Push; 29 import org.objectweb.dream.message.manager.MessageManager; 30 import org.objectweb.dream.protocol.Process; 31 import org.objectweb.fractal.api.NoSuchInterfaceException; 32 import org.objectweb.fractal.api.control.IllegalBindingException; 33 import org.objectweb.fractal.api.control.IllegalLifeCycleException; 34 35 41 public class LeaderFaultForwarderImpl extends AbstractComponent 42 implements 43 ProcessMembershipUpdateNotification 44 { 45 46 50 51 protected Push outPushItf; 52 53 54 protected MessageManager messageManagerItf; 55 56 60 63 public LeaderFaultForwarderImpl() 64 { 65 } 66 67 71 74 public void newBackup(Process backup) 75 { 76 78 } 79 80 83 public void newLeader(Process leader) 84 { 85 87 } 88 89 92 public void newProcesses(Process [] processes) 93 { 94 96 } 97 98 102 106 public void bindFc(String clientItfName, Object serverItf) 107 throws NoSuchInterfaceException, IllegalBindingException, 108 IllegalLifeCycleException 109 { 110 super.bindFc(clientItfName, serverItf); 111 if (clientItfName.equals(Push.OUT_PUSH_ITF_NAME)) 112 { 113 outPushItf = (Push) serverItf; 114 } 115 else if (clientItfName.equals(MessageManager.ITF_NAME)) 116 { 117 messageManagerItf = (MessageManager) serverItf; 118 } 119 } 120 121 124 public String [] listFc() 125 { 126 return new String []{Push.OUT_PUSH_ITF_NAME, MessageManager.ITF_NAME}; 127 } 128 129 } | Popular Tags |