Apache Camel - потреблять сообщения, только если размер очереди больше - PullRequest
Новая
       68

Apache Camel - потреблять сообщения, только если размер очереди больше

2 голосов
/ 08 января 2020

Я пытаюсь найти способ потребления сообщений в очереди ActiveMQ, только если число сообщений превышает определенное число. Любые идеи? Обычно, если вы используете синтаксис: 

from("jms:start-queue")
   .process(new SampleProcessor())
   .to("jms:end-queue")
.end();

, сообщения используются, как только они "передаются в процессор".

Спасибо

1 Ответ

1 голос
/ 08 января 2020

Возможно ли aggregate сообщения с completionSize? 

from("...")
    .aggregate(constant(true), new MyListAggregator())
    .completionSize(x)
    .to("...")

Пожалуйста, см. эту статью об агрегации

...