1 5 package com.tc.net.groups; 6 7 import com.tc.async.api.Sink; 8 9 public interface GroupManager { 10 11 public NodeID join() throws GroupException; 12 13 public NodeID getLocalNodeID() throws GroupException; 14 15 public void sendAll(GroupMessage msg) throws GroupException; 16 17 public GroupResponse sendAllAndWaitForResponse(GroupMessage msg) throws GroupException; 18 19 public void sendTo(NodeID node, GroupMessage msg) throws GroupException; 20 21 public GroupMessage sendToAndWaitForResponse(NodeID nodeID, GroupMessage msg) throws GroupException; 22 23 public void registerForMessages(Class msgClass, GroupMessageListener listener); 24 25 public void routeMessages(Class msgClass, Sink sink); 26 27 public void registerForGroupEvents(GroupEventsListener listener); 28 29 public void zapNode(NodeID nodeID); 30 31 } 32 | Popular Tags |