@Test public void testViewAccepted() throws Exception { }
@Override public void viewAccepted(final View view) { Set<String> addresses = view.getMembers().stream().map(Address::toString).collect(Collectors.toSet()); store.keepHandlesFor(addresses); log.info("Cluster view change: " + view); }
JgroupsMessageReceiver extends ReceiverAdapter implements RequestHandler { @Override public void viewAccepted(final View view) { Set<String> addresses = view.getMembers().stream().map(Address::toString).collect(Collectors.toSet()); store.keepHandlesFor(addresses); log.info("Cluster view change: " + view); } }
JgroupsMessageReceiver extends ReceiverAdapter implements RequestHandler { @Override public void viewAccepted(final View view) { Set<String> addresses = view.getMembers().stream().map(Address::toString).collect(Collectors.toSet()); store.keepHandlesFor(addresses); log.info("Cluster view change: " + view); } JgroupsMessageReceiver(Map<Class, Responder> responders, RemoteServiceHandlesStore store); }
JgroupsMessageReceiver extends ReceiverAdapter implements RequestHandler { @Override public void viewAccepted(final View view) { Set<String> addresses = view.getMembers().stream().map(Address::toString).collect(Collectors.toSet()); store.keepHandlesFor(addresses); log.info("Cluster view change: " + view); } JgroupsMessageReceiver(Map<Class, Responder> responders, RemoteServiceHandlesStore store); void setMyAddress(Address myAddress); Responder addResponder(Class clazz, Responder responder); @Override void receive(final Message msg); @Override void viewAccepted(final View view); @Override Object handle(Message msg); }
JgroupsMessageReceiver extends ReceiverAdapter implements RequestHandler { @Override public void viewAccepted(final View view) { Set<String> addresses = view.getMembers().stream().map(Address::toString).collect(Collectors.toSet()); store.keepHandlesFor(addresses); log.info("Cluster view change: " + view); } JgroupsMessageReceiver(Map<Class, Responder> responders, RemoteServiceHandlesStore store); void setMyAddress(Address myAddress); Responder addResponder(Class clazz, Responder responder); @Override void receive(final Message msg); @Override void viewAccepted(final View view); @Override Object handle(Message msg);  }