申し訳ありませんが、私は自分の質問に答えました-それは実際には単なるSEDAです.「BlockingQueue」を見たとき、キューが読み取られるまでSEDAがブロックされると思いました...もちろんナンセンスです. SEDA だけで十分です。質問への回答
完全に私を悩ませている問題があります。接続先の会社からカスタム エンドポイントが提供されましたが、エンドポイントはフィードへのハートビートを維持し、特定のサイズを超えるメッセージを送信すると非常に時間がかかります。ブロッキングとハートビートが失われ、接続がダウンするルートで処理する
明らかに、これはスムーズな操作を維持するために非グラフィック スレッドでイベントを処理することに似ています。しかし、ラクダでこれをどのように達成するかはわかりません。基本的に、結果をキューに入れ、別のスレッドに入れたいと思っています。
from( "custom:endpoint" )
.process( MyProcesor )
.to( "some-endpoint")