2017-01-26 10 views
1

저는 Akka 클러스터에 두 개의 노드가 있습니다. 두 노드 중 하나가 다운되면Akka 클러스터 : Reachable 이벤트가 발생하지 않는 이유는 무엇입니까?

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

, 나는이 Unreachable 이벤트를 수신하고 나는 일부 로그 다음과 같은 나에게 경고를 몇 초마다 수신을 시작합니다

나는 함께 클러스터의 모든 ClusterDomainEvent에 가입 : 아래 노드가 돌아올 때

Association with remote system [akka.tcp://[email protected]:2554] has failed 

,이 노드가 다시 연결할 수 있는지 감지하도록 로그를 중지하지만 난 여전히 ReachableMember 이벤트를하지 않습니다.

무엇이 누락 되었습니까? 이 클러스터 이벤트를 수신하려면 왜해야합니까?

답변

0

는 그래서 classOf[ReachabilityEvent]

cluster.subscribe(
    self, 
    InitialStateAsEvents, 
    classOf[MemberEvent], 
    classOf[ReachabilityEvent]) 
으로 클러스터 이벤트를 구독하는 것입니다 수행하는 방법