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