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