Сделал коннектор к кластеру через jgroups. Мои экземпляры соединителей работают правильно и получают другие сообщения, когда они работают на одной машине, но они не перехватывают другие сообщения, когда они работают на двух разных машинах. Мой класс соединителя JGroups:
public class JGroupsMulticastConnector implements Sender, Listener {
JChannel basicChannel = null;
String clusterName = "";
public JGroupsMulticastConnector( String clusterName) {
this.clusterName = clusterName;
try {
basicChannel = new JChannel();
} catch (Exception e) {
MyLogger.error(e, name);
}
}
public void init() {
try {
basicChannel.connect(clusterName);
basicChannel.setReceiver(new ReceiverAdapter(){
@Override
public void receive(org.jgroups.Message msg) {
System.out.println(name+":"+"Got a Message");
super.receive(msg);
}
});
} catch (Exception e) {
MyLogger.error(e, name);
}
}
public void shutdown() {
basicChannel.disconnect();
}
@Override
public void send(Message msg) {
basicChannel.send(msg);
}
}