2017-05-07 12 views
1

AKKAクラスタを使用し始めています。私は、ある役者が特定のタスクを実行することを希望します。そのアクタが停止している場合は、他のアクタがそれを実行する必要があります。私はLeaderChangedイベントを追跡し、現在のActorがリーダーであるかどうかをチェックすることでこれを行うと考えました。何かのようにakkaクラスタを使用してユニークなタスクを実行する慣用方法

case LeaderChanged => 
if ((cluster.state.leader.map(_ == cluster.selfAddress).getOrElse(false)) 
//do some task 

それを行う慣用方法ですか?

答えて

関連する問題