import org.jgroups.*;
public class ClusterManager implements Receiver {
private JChannel channel;
public ClusterManager() throws Exception {
channel = new JChannel();
channel.setReceiver(this);
channel.connect("my-cluster");
}
public void sendMessage(String message) throws Exception {
channel.send(new Message(null, null, message));
}
public void receive(Message msg) {
System.out.println("Received message: " + msg.getObject());
}
public void viewAccepted(View newView) {
System.out.println("New members: " + newView.getMembers());
}
public void close() {
channel.close();
}
public static void main(String[] args) throws Exception {
ClusterManager manager = new ClusterManager();
manager.sendMessage("Hello, cluster!");
manager.close();
}
}
