java - Spring Integration 在迭代器上拆分时抑制异常

Question

以以下场景为例：我通过迭代器拆分消息。.handle()如果在迭代一个元素时抛出异常，则跳过所有剩余元素并获取下一条消息。我需要抑制任何可能的异常，以便处理迭代器中的所有元素。

例如，由于我使用的是迭代器而不是列表，因此我无法使用.aggregate().

请问，我怎样才能获得所需的行为......？

• Spring Boot Starter 集成 1.3.0
• Spring 集成 4.2.1
• Java DSL 1.1.1

提前致谢！

Answer 1

就放在.channel(c -> c.executor(...))后面.split()。

在这种情况下，您的所有消息将被并行处理（至少），并且所有下游错误将被包装ErrorMessage并发送到errorChannel（默认情况下）。