2017-01-26 6 views
1

私はAkkaクラスタに2つのノードを持っています。Akkaクラスター:なぜReachableイベントを受け取らないのですか?

私は、クラスタのすべての ClusterDomainEventに加入

:2つのノードのいずれかがダウンしたとき、私はUnreachableイベントを受け取り、私は次のようにいくつかのログに私を警告する数秒ごとに受信を開始

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

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

ダウンノードが戻ってきたとき、ノードが再び到達可能であることが検出されたので、ログは、停止するが、私はまだReachableMemberイベントを得ることはありません。

私には何が欠けていますか?なぜこのクラスタイベントを受け取るために私はしなければならないのですか?

答えて

0

それを行う方法はclassOf[ReachabilityEvent]

でクラスタイベントをサブスクライブすることがあるので、

cluster.subscribe(
    self, 
    InitialStateAsEvents, 
    classOf[MemberEvent], 
    classOf[ReachabilityEvent]) 
関連する問題