Akka cluster: почему я не получаю событие Reachable?

Question

У меня есть два узла в кластере Akka.

подписаться на все ClusterDomainEvent кластера с:

cluster.subscribe(
    self, 
    InitialStateAsEvents, 
    classOf[ClusterDomainEvent]) 

Когда один из двух узлов вниз, я получаю Unreachable событие, и я начинаю получать некоторые журналы каждые несколько секунд, которые предупреждают меня следующие :

Association with remote system [akka.tcp://application@127.0.0.1:2554] has failed 

Когда вниз узел вернется, журналы остановка, поэтому оно было обнаружено, что узел снова достижим, но я до сих пор не получает ReachableMember события.

Что мне не хватает? Почему я должен делать это, чтобы получить это кластерное событие?

Answer 1

Способ сделать это, чтобы подписаться на события кластера с classOf[ReachabilityEvent]

Так

cluster.subscribe(
    self, 
    InitialStateAsEvents, 
    classOf[MemberEvent], 
    classOf[ReachabilityEvent])