Apache Camel聚合器中的并行

Question

我有一个骆驼路线配置，如下所示：

from("seda:logCall?concurrentConsumers=50")
                    .aggregate(header("EXCHANGE_ID"), new CustomAggregator())
                    .completionSize(2)
                    .parallelProcessing()
                    .to("bean:someAdapter?method=someMethod");

我想要实现的是并行处理，这意味着消息应该由聚合器和bean并行处理(在聚合之后)。但是，在调试时，我看到了聚合块(运行在一个线程中)。Bean并行地处理消息，所以它是可以的。

我应该如何配置聚合器来并行聚合传入的消息？

Answer 1

你可以试试

from("seda:logCall?concurrentConsumers=50")
    .threads().executorService(Executors.newCachedThreadPool())
    .aggregate(header("EXCHANGE_ID"), new CustomAggregator())
    .completionSize(2)
    .parallelProcessing()
    .to("bean:someAdapter?method=someMethod");