java - Camel : Iterate the elements in the header, 并行处理

Question

我将 url 列表存储在 Apache Camel header 中，下面是代码，

List<String> supplierHotelRefs = new ArrayList();
supplierHotelRefs.add("a.com");
supplierHotelRefs.add("b.com");
supplierHotelRefs.add("c.com");
 exchange.getIn().setBody(supplierHotelRefs);

现在我需要迭代 header 中存在的此列表并调用 url。这应该是并行 Activity 。我尝试使用 split(..) ，如果我们将列表存储在正文中，它可以正常工作，但由于某些限制，我无法将其存储在正文中。如果我获得代码来迭代和并行处理 Camel header 中存在的集合，这将很有帮助。

问候，拉加万

Answer 1

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

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")

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