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

Question

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

したがって、これらの「再登録」メッセージを再起動中に子供に配信するにはどうすればよいですか？

Answer 1

再起動フック（http://doc.akka.io/docs/akka/snapshot/scala/actors.html#Restart_Hooks）：preRestart APIとpostRestart APIを使用できます。

子供の俳優のpreRestartについて、あなたは子供の俳優が再開されることを管理者に知らせる必要があり、監督はメッセージの送信を中断する必要があります。

子供の俳優のpostRestartで、あなたは子供が利用可能であることを監督者に知らせる必要があり、監督者はメッセージの送信を再開する必要があります。

Answer 2

あなたが

context.system.eventStream.subscribe(myListenerActorRef, classOf[DeadLetter]) 
... 
def receive = { 
    case DeadLetter(msg, from, to) => 
    //Do my custom stuff here 
} 

、店舗で死んだ手紙に加入し、それらを再度送信することができます。