Spring集成在分割迭代器時抑制異常

Question

以下面的方案爲例： 我在Iterator上分割了一條消息。如果在遍歷一個元素時在.handle()內引發異常，則跳過所有其餘元素並獲取下一條消息。 我需要抑制任何可能的異常，以便處理迭代器中的所有元素。

因爲我使用Iterator而不是List，例如，我無法使用.aggregate()解決此問題。

請問我該如何設法達到理想的行爲......？

• 春天引導入門整合1.3.0
• Spring集成4.2.1
• 的Java DSL 1.1.1

提前感謝！

Answer 1

只需在.split()之後.channel(c -> c.executor(...))。

在這種情況下，所有消息都將並行處理（至少），並且所有下游錯誤將被包裝到ErrorMessage中併發送到errorChannel（默認情況下）。