java - 使用 Camel 对 ActiveMQ 消息队列进行动态节流

Question

我是一个 ActiveMQ/Camel 菜鸟，有一个特定的场景，我首先想知道这是否可能，其次是否有人​​可以提供一些指导。

基本上我需要对队列执行动态限制。即能够在运行时设置从队列中消耗特定消息组的速率。

因此，例如，我可以添加一组以每秒 10 条的速度使用的消息，另一组以每秒 1 条的速度使用，依此类推。

我知道在 Camel 中设置路由和消息分组到队列等的基础知识，但无法从文档中弄清楚这一点。

Answer 1

你可以只使用Camel现有的throttler然后为每种类型的消息使用不同的队列，您需要配置不同的节流速率？

例如

from("activemq:Queue1.Input").
    throttle(20).
    to("activemq:Queue1.Output");  
from("activemq:Queue2.Input").
    throttle(5).
    to("activemq:Queue2.Output");