ブロッキング キューから取得するなど、アクター内でスリープ/待機アクティビティを実行する必要がある場合、何か問題はありますか?
私のユースケース: 異種ソース (ファイル、SMS、電子メール) からデータが供給される基本的な ETL を実装しています。イベントで抽出-変換-ロード シーケンス フローをトリガーできるソース固有のレシーバーがあります。Akka アクターを使用してフローを調整しています (主に並列処理と障害処理/再試行を実現するため)。
「プル」レシーバーであるファイルと電子メールの場合、イベントの受信時に新しいフローがトリガーされます。「プッシュ」レシーバーである SMS の場合、エクストラクタが永続的なキューをリッスンし、レシーバーが実際にイベントの受信時にキューに入る単一のフローを用意する予定です。
fork-join ディスパッチャと単一の etl アクターを使用しています。