春の統合イテレータを分割する際に例外を抑制する

Question

たとえば、次のシナリオを考えてみましょう。 メッセージをIteratorで分割します。ある要素を反復処理中に例外が.handle()の内部にスローされた場合、残りの要素はすべてスキップされ、次のメッセージが取得されます。 イテレータのすべての要素が処理されるように、例外が発生しないようにする必要があります。

Listの代わりにIteratorを使用しているので、.aggregate()を使って解決できません。

どうすれば希望の動作を得ることができますか？

• 春ブーツ初心者の統合1.3.0
• 春の統合4.2.1
• のJava DSL 1.1.1

事前に

ありがとう！

Answer 1

.split()の直後に.channel(c -> c.executor(...))を配置してください。

この場合、すべてのメッセージは並列処理され（少なくとも）、すべてのダウンストリームエラーはErrorMessageにラップされ、errorChannel（デフォルト）に送信されます。