Параллель в Apache Camel Aggregator - PullRequest
Новая
       13

Параллель в Apache Camel Aggregator

1 голос
/ 08 апреля 2019

У меня есть конфигурация маршрута Camel, как показано ниже: 

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

Чего я хочу добиться, так это параллельной обработки до конца, то есть сообщения должны обрабатываться параллельно агрегатором и компонентом (после агрегации). Однако, когда я отлаживал, я видел, что агрегатные блоки (запускаются в одном потоке). Бин обрабатывает сообщения параллельно, так что все в порядке.

Как настроить агрегатор для агрегирования входящих сообщений?

...