java - Apache Camel - 仅当队列大小大于

Question

我试图找到仅当消息计数大于某个数量时在 ActiveMQ 队列中使用消息的方式。
有任何想法吗？
通常，如果您使用以下语法:

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("...")

请查看 this articale about aggregation