我面臨Akka監督演員的問題。當子actor在未來結果的onFailure方法中拋出異常時,主管不處理該錯誤(我想在出現ConnectException時重新啓動子進程)。 我使用的是Akka 2.3.7。 這是主管演員: class MobileUsersActor extends Actor with ActorLogging {
import Model.Implicits._
我試圖讓演員Worker在其自己的導師Mngr重新啓動時,不重新啓動其子演員SubWorker。即使在覆蓋和postRestart的Worker之後,我仍然沒有成功。日誌仍顯示SubWorker直到重新啓動。我是Akka和Actor模特的新手,我不知道我做錯了什麼。 case class Start()
case class ThrowExp()
class Mngr extends Act
如果我在Scala中爲演員定義主管策略,如何使用OneForOneStrategy和AllForOneStrategy?有沒有簡單的方法來組合它們,或者我必須定義一個自定義SupervisorStrategy? 下面是一個例子: class MyActor extends Actor {
override val supervisorStrategy = OneForOneStrateg
讀阿卡DOC:http://doc.akka.io/docs/akka/2.2.3/AkkaScala.pdf其部分 2.2.1 Hierarchical Structure
The only prerequisite is to know that each actor has exactly one supervisor,
which is the actor that created i
我將探索Akka生命週期和Akka演員監督策略。我正在創建我自己的例外情況,並重寫public SupervisorStrategy supervisorStrategy()探索阿卡生命週期及其恢復策略的方法。以下是我的代碼: public class JavaActor extends AbstractActor {
@Override
public PartialFunction<Obj