我试图找到仅当消息数大于一定数量时才消费ActiveMQ队列中的消息的方法。 有任何想法吗？ 通常如果您使用语法:
from("jms:start-queue")
.process(new SampleProcessor())
.to("jms:end-queue")
.end();
消息一旦“传递到处理器”就会被消耗。
谢谢
最佳答案
是否可以使用 completionSize 来聚合消息？
from("...")
.aggregate(constant(true), new MyListAggregator())
.completionSize(x)
.to("...")
关于java - Apache Camel - 仅当队列大小大于时才使用消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/59643039/