1
AKKAクラスタを使用し始めています。私は、ある役者が特定のタスクを実行することを希望します。そのアクタが停止している場合は、他のアクタがそれを実行する必要があります。私はLeaderChangedイベントを追跡し、現在のActorがリーダーであるかどうかをチェックすることでこれを行うと考えました。何かのようにakkaクラスタを使用してユニークなタスクを実行する慣用方法
case LeaderChanged =>
if ((cluster.state.leader.map(_ == cluster.selfAddress).getOrElse(false))
//do some task
それを行う慣用方法ですか?