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（默认情况下）。