1

我在 Akka 集群中有两个节点。

我订阅了所有ClusterDomainEvent集群：

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

当两个节点之一关闭时，我会收到一个Unreachable事件，并且每隔几秒就会收到一些日志，警告我如下：

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

当down节点回来时，日志停止，因此检测到该节点再次可达但我仍然没有收到ReachableMember事件。

我错过了什么？我为什么要接收这个集群事件？

4

1 回答 1

0

这样做的方法是订阅集群事件classOf[ReachabilityEvent]

所以

cluster.subscribe(
  self,
  InitialStateAsEvents,
  classOf[MemberEvent],
  classOf[ReachabilityEvent])
于 2017-02-08T10:56:45.387 回答