2017-05-07 28 views
1

我開始使用AKKA集羣。我希望某個任務將由一名演員完成。如果該演員倒下,則應該由其他演員執行。我認爲通過跟蹤LeaderChanged事件來做到這一點,並檢查當前Actor是否是領導者。類似於使用akka集羣執行獨特任務的慣用方式

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

是這樣做的慣用方法嗎?

回答