2

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

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

请问,我怎样才能获得所需的行为......?

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

提前致谢!

4

1 回答 1

2

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

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

于 2016-07-29T14:22:20.117 回答