String message = "Hello, world!";
byte[] data = message.getBytes();
channel.setReceiver(new Receiver() {
@Override
public void receive(Message msg) {
byte[] data = msg.getRawBuffer();
String message = new String(data);
System.out.println("Received message: " + message);
}
});
ProtocolStack stack = new ProtocolStack();
stack.addProtocol(new UDP().setValue("mcast_group_addr", InetAddress.getByName("224.0.0.1")))
.addProtocol(new PING())
.addProtocol(new MERGE2())
.addProtocol(new FD_SOCK())
.addProtocol(new FD_ALL().setValue("timeout", 12000).setValue("interval", 3000))
.addProtocol(new VERIFY_SUSPECT())
.addProtocol(new BARRIER())
.addProtocol(new NAKACK2())
.addProtocol(new UNICAST3())
.addProtocol(new STABLE())
.addProtocol(new GMS())
.addProtocol(new UFC())
.addProtocol(new MFC())
.addProtocol(new FRAG2());
channel.setProtocolStack(stack);
channel.connect("myGroup");
