Apache Camel: агрегатор не завершается, свойство SPLIT_COMPLETEJAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 Apache Camel: агрегатор не завершается, свойство SPLIT_COMPLETE

Сообщение 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.
Обмен никогда не завершается.
Агрегация никогда не завершается.
Эта проблема начала возникать после перехода на Apache Camel 4.6.0. Кто-нибудь сталкивался с подобной проблемой или знает, что может быть причиной такого поведения?
Будем очень признательны за любую помощь или предложения. Спасибо!

Подробнее здесь: https://stackoverflow.com/questions/790 ... e-property
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «JAVA»