akka-supervision

1熱

1答えて

私はAkkaの監督のためにどのようなアプローチが必要なのかよくわかりません。私は、メッセージがトリガーされたときにFTPサーバーからのファイルをリストするAkkaアクターを持っています。接続が壊れていると、アクタは監視をトリガする例外（IOExceptionなど）で失敗します。この時点で、私は2つの選択肢を参照してください。を私は方法で（例えばmaxNrOfRetries = XYなど）のパラ

1熱

1答えて

Akka：他の（子供以外の）俳優の中のある俳優の失敗をどうやって捉えることができますか？

私は2人の俳優があります。システム内のいくつかのプロセスを処理 ProcessManager（例えば、ユーザ登録、購入、など）通知 - いくつかのエラーがProcessManagerで発生した場合、ユーザーに通知する必要がありますが。 ProcessManagerアクターの失敗を捕捉する必要があります（たとえば、ActorInitializationExceptionや最大再起動時間に達し、プロ

0熱

2答えて

アクカアクタは時間の経過後に再起動します

私は、いくつかの子アクタを作成する管理者アクタを持っています。私は私が子供を再起動する前の5秒を言わせてのためにしたいように、私は、この再起動にタイムアウトを導入できるか知りたいのですが override val supervisorStrategy = OneForOneStrategy() { case _ => logger.info("doing rest

0熱

1答えて

Akka：Javaを使用して登録されていないカスタムakka監督戦略

AkkaライフサイクルとAkkaアクター監督戦略を探そうとしています。私は自分自身の例外を作成し、akkaのライフサイクルとその回復戦略を調べるためにpublic SupervisorStrategy supervisorStrategy()メソッドをオーバーライドしています。私は続けてEsclateExceptionログを投げると俳優を終了していないとき方法で public class Java

0熱

1答えて

Akka-Java：パイプパターンを使用して親の将来のメッセージを受け取ることができません

1つの親に対して1つの子アクターを作成しています。私の子供の俳優は、いくつかのビジネスロジックを実行し、scala Futureに価値を返します。親にFutureメッセージを送信すると、私は将来のメッセージをキャッチできません。以下は、私のコードです：子役 public class FetchDevicesIds extends AbstractActor { private final L

0熱

1答えて

はなぜアッカ・ストリームの再起動の監督は、再起動しませんが、ちょうど

は、この単純な流れを考えてみましょ再開：は Source(1 to 5) .mapAsync(1) { i => if (i % 3 == 0) Future.failed(new Exception("I don't like 3")) else Future.successful(i) } .withAttributes( ActorAttributes.su

1熱

2答えて

Akka - 子供が例外を抱えた後に親が子にメッセージを送信する方法

をchildという俳優にという1人のメッセージを送信するparent俳優がいるとします。子が現在のメッセージの処理を終了すると、子に新しいメッセージを送信することを親に通知します。子供が特定のメッセージにcrashs場合でも、このループを維持するために、私は親にSupervisorStrategyを追加しました： private static SupervisorStrategy strate

0熱

1答えて

アッカカフカストリームsupervison戦略は、私がアッカストリームカフカのアプリケーションを実行していると私は、そのようなブローカーがダウンして、ストリームの消費者は、停止タイムアウト後に死亡した場合、そのストリームの消費者の監督の戦略を組み込みたい

を動作していませんスーパーバイザはコンシューマを再起動できます。 UserEventStream： import akka.actor.{Actor, PoisonPill, Props} import akka.kafka.{ConsumerSettings, Subscriptions} import akka.kafka.scaladsl.Consumer import akka.st

3熱

1答えて

Akka：OneForOneStrategyとAllForOneStrategyを組み合わせる方法

私がOneForOneStrategyとAllForOneStrategyの両方を使用するにはどうすればScalaのアクタのスーパーバイザ戦略を定義できますか？それらを組み合わせる簡単な方法はありますか？またはカスタムを定義する必要がありますかSupervisorStrategy？ class MyActor extends Actor { override val supervisor

1熱

2答えて

Akkaアクターの再起動時に "init"メッセージを再送信

私は子供の "コンシューマー"アクターをいくつかの外部データストリームに接続し、メッセージを解析してアプリケーション内でさらに転送します。この「プロデューサ」システムにはpub-subアーキテクチャがありますが、再接続後にサブスクリプションを復元することはありません。現在、これらのサブスクリプションを親アクターに保存してスーパーバイザに再送信しますが、問題は子プロセスが再起動している間にデッドレタ