akka-supervision

    3熱度

    1回答

    我面臨Akka監督演員的問題。當子actor在未來結果的onFailure方法中拋出異常時,主管不處理該錯誤(我想在出現ConnectException時重新啓動子進程)。 我使用的是Akka 2.3.7。 這是主管演員: class MobileUsersActor extends Actor with ActorLogging { import Model.Implicits._

    0熱度

    2回答

    爲了進行調試,我希望以編程方式獲取當前在系統中的非終止actor。 任何能給\可以轉換爲文本表示的演員層次結構的當前狀態也是足夠的。 我該如何執行此操作?

    3熱度

    1回答

    我試圖讓演員Worker在其自己的導師Mngr重新啓動時,不重新啓動其子演員SubWorker。即使在覆蓋和postRestart的Worker之後,我仍然沒有成功。日誌仍顯示SubWorker直到重新啓動。我是Akka和Actor模特的新手,我不知道我做錯了什麼。 case class Start() case class ThrowExp() class Mngr extends Act

    4熱度

    2回答

    假設主管演員定義一定的策略: private static SupervisorStrategy strategy = new OneForOneStrategy(10, Duration.create("1 minute"), DeciderBuilder. match(Exception.class, e -> resume()). matchAny

    1熱度

    2回答

    假設我有一個parent參與者發送一條消息至其child角色。 當孩子完成當前消息的處理後,它會通知父母在該消息中將向孩子發送新消息。 爲了保持這個循環即使孩子crashs上某個消息,我添加了一個SupervisorStrategy父: private static SupervisorStrategy strategy = new OneForOneStrategy(10, Dura

    0熱度

    1回答

    我運行一個阿卡流卡夫卡應用程序,我想結合的流消費者的監督策略,例如,如果經紀人下降,流消費者停止超時後死亡,主管可以重新啓動消費者。 這裏是我的完整代碼: UserEventStream: import akka.actor.{Actor, PoisonPill, Props} import akka.kafka.{ConsumerSettings, Subscriptions} import

    3熱度

    1回答

    如果我在Scala中爲演員定義主管策略,如何使用OneForOneStrategy和AllForOneStrategy?有沒有簡單的方法來組合它們,或者我必須定義一個自定義SupervisorStrategy? 下面是一個例子: class MyActor extends Actor { override val supervisorStrategy = OneForOneStrateg

    1熱度

    1回答

    我不確定Akka監督遵循什麼方法。 我有一個Akka actor在消息觸發時從FTP服務器列出文件。如果連接中斷,actor將失敗,並觸發一個異常(比如IOException),這將觸發監督。在這一點上,我看到了兩個備選方案: 我一直在恢復/重啓演員,直到服務器備份,可能與指數退避 我的方式設置的參數(如maxNrOfRetries = XY)主管將在xy時間後放棄並停止演員 第一個策略看起來很浪

    2熱度

    1回答

    讀阿卡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

    0熱度

    1回答

    我將探索Akka生命週期和Akka演員監督策略。我正在創建我自己的例外情況,並重寫public SupervisorStrategy supervisorStrategy()探索阿卡生命週期及其恢復策略的方法。以下是我的代碼: public class JavaActor extends AbstractActor { @Override public PartialFunction<Obj