一部のステージが http 呼び出しである Akka ストリームを作成しようとしています。http 呼び出しは時々失敗する可能性がある (そして失敗する) ため、関連するデータを別のキュー (アプリケーションの外部にある場合もあります) に配置し、しばらくしてからそれらをプルし、ストリームでそれらを消費することをお勧めします。
http 呼び出しにスプレー クライアントを使用しています。しかし、私は他のクライアント (新しい akka-http を含む) に対してオープンです。
これを達成するための最もクリーンな方法は何ですか? ステージがブロックされるため、同期再試行を行うことはできません。現在、失敗した http リクエストを raabitmq に入れ、すべての http ステージの前に RMQ コンシューマー ソースとマージ ノードを追加しています。これで目的は達成できますが、ストリーム コードが見苦しく管理しにくくなります。単純な線形トポロジーでさえ、このアプローチでは複雑なグラフになります。
主に簡単な構成と背圧のために、(プレーンな akka ソリューション上で) Akka ストリームを使用しています。
この場合、どのような代替手段がありますか (akka-stream の内外で)。他の設計上の制約については、Akka ソリューションに固執したいと思います。