Apache Camel - 仅当队列大小大于

Question

我试图找到仅当消息数大于一定数量时才消费 JMS 队列中的消息的方法。有任何想法吗？通常如果您使用语法：

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

消息一旦“传递到处理器”就会被消耗。

谢谢

Answer 1

是否可以用

aggregate

completionSize

来标记消息？

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