Apache Camel — разделение, токенизация и агрегирование не завершаются при использовании пула Exchange-Factory ⇐ JAVA

[Anonymous]

У меня возникла проблема с маршрутом Apache Camel после перехода на версию 4.6.0. Проблема в том, что обмен никогда не устанавливается на выполнение, когда в пуле находится фабрика обмена вместо прототипа значения по умолчанию, а свойство SPLIT_COMPLETE всегда остается ложным . Это приводит к тому, что агрегирование никогда не завершается.
Вот мое определение маршрута:

Код: Выделить всё

from(direct("input"))
.routeId("input-route")
.setHeader(HttpHeaders.CONTENT_TYPE, constant(MediaType.MULTIPART_FORM_DATA_VALUE))
.unmarshal().mimeMultipart()
.split().tokenize("\n").streaming()
.aggregate(constant(true), new GroupedBodyAggregationStrategy())
.completionSize(1000)
.completionPredicate(exchangeProperty(Exchange.SPLIT_COMPLETE))
.setExchangePattern(ExchangePattern.InOnly)
.multicast().parallelProcessing()
.to(direct("output"));

Ожидаемое поведение:
Использование фабрики обмена объединено в пул, агрегатор должен завершиться, когда будет достигнут размер пакета или когда для свойства SPLIT_COMPLETE установлено значение true.
Обмен должен быть помечен как выполненный после обработки.
Фактическое поведение:
Свойство SPLIT_COMPLETE всегда имеет значение false.
Обмен никогда не завершается.
Агрегация никогда не завершается.
MulticastProcessor.MulticastTask#iterator продолжает расти и заканчивается, что приводит к OOM.
Эта проблема начала возникать после перехода на Apache Camel 4.6.0. Кто-нибудь сталкивался с подобной проблемой или знает, что может быть причиной такого поведения?
Будем очень признательны за любую помощь или предложения. Спасибо!

Подробнее здесь: https://stackoverflow.com/questions/790 ... g-exchange