+ } else if (message instanceof ClusterEvent.MemberDowned) {
+ final ClusterEvent.MemberDowned event = (ClusterEvent.MemberDowned) message;
+ if (Cluster.get(getContext().system()).selfMember().equals(event.member())) {
+ LOG.warn("This member has been downed, restarting");
+
+ callback.apply();
+ }