1

我怎样才能让我的竞争消费者保持完全的活力？
Camel 实现要求提供 concurrentConsumers 值。但是假设一个新的消费者启动并开始消费发送者的消息。那么我将如何保持并发消费者的数量呢？

4

1 回答 1

2

我假设你在谈论 JMS 消费者......

如果是这样，您可以设置 concurrentConsumers 和 maxConcurrentConsumers 以允许活动消费者线程的数量根据需求增长/缩小。像这样的东西会明确地设置一条路线......

from("activemq:queue:input?concurrentConsumers=1&maxConcurrentConsumers=5")
.to("log:+++consumed+++");

也就是说，如果您有其他路由（或非路由消费者，如 Spring JMSTemplates 等）从同一资源（输入队列）开始消费，那么总消费者的数量可能会更高......

您可以随时在 AMQ Web 控制台或通过 JMX 查看活跃消费者的总数

于 2012-05-31T22:02:15.127 回答