Camel:迭代头中的元素,并行处理它

您可以在标题中设置列表并在该标题上拆分。

exchange.getIn().setHeader("supplierHotelRefs",supplierHotelRefs);

在路由定义中,可以根据header属性进行拆分,并并行处理它们。

from("").....
//split based on the header
split(header("supplierHotelRefs"))
//process every split exchange parallely
.parallelProcessing()
//end split block
.end()
//continue route definition after split
.log("completed split processing")

请注意,调用线程仍将等待所有拆分消息完成。

你可以用 收件人列表EIP 看见 http://camel.apache.org/recipient-list.html

您必须创建一个包含所有收件人的列表,并将该列表存储到标题中。我在代码中观察到,您并没有将列表设置为标题,而是作为一个主体。你得做点什么

List<String> supplierHotelRefs = new ArrayList();
supplierHotelRefs.add("http4://a.com");
supplierHotelRefs.add("http4://b.com");
supplierHotelRefs.add("http4://c.com");
exchange.getIn().setHeader("yourHeaderName", supplierHotelRefs);

正如您所注意到的,列表中的每个元素都有一个有效的url http4 骆驼组件。此组件用于进行http调用。你可以把任何你想要的东西放进这个列表(其他骆驼组件)。

然后使用收件人列表EIP,告知所有收件人都已进入上一个创建的标题。parallelProcessing=true,并行调用列表中的所有项。这在XML DSL中称为:

<recipientList parallelProcessing="true">
   <header>yourHeaderName</header>
</recipientList>  

或者在Java DSL中:

from("...")
  ...
  .recipientList(header("yourHeaderName"));