import org.jgroups.JChannel;
import org.jgroups.Message;
import org.jgroups.ReceiverAdapter;
import org.jgroups.View;
public class JGroupsExample extends ReceiverAdapter {
private JChannel channel;
public JGroupsExample() throws Exception {
channel = new JChannel();
channel.setReceiver(this);
channel.connect("myCluster");
}
public void viewAccepted(View newView) {
System.out.println("** View: " + newView);
}
public void receive(Message msg) {
System.out.println("** Received message: " + msg);
}
public void sendMessage(String message) throws Exception {
Message msg = new Message(null, null, message);
channel.send(msg);
}
public void close() {
channel.close();
}
public static void main(String[] args) {
try {
JGroupsExample example = new JGroupsExample();
example.sendMessage("Hello JGroups!");
example.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
