我是一个 ActiveMQ/Camel 菜鸟,有一个特定的场景,我首先想知道这是否可能,其次是否有人可以提供一些指导。
基本上我需要对队列执行动态限制。即能够在运行时设置从队列中消耗特定消息组的速率。
因此,例如,我可以添加一组以每秒 10 条的速度使用的消息,另一组以每秒 1 条的速度使用,依此类推。
我知道在 Camel 中设置路由和消息分组到队列等的基础知识,但无法从文档中弄清楚这一点。
最佳答案
你可以只使用Camel现有的throttler然后为每种类型的消息使用不同的队列,您需要配置不同的节流速率?
例如
from("activemq:Queue1.Input").
throttle(20).
to("activemq:Queue1.Output");
from("activemq:Queue2.Input").
throttle(5).
to("activemq:Queue2.Output");
关于java - 使用 Camel 对 ActiveMQ 消息队列进行动态节流,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/454084/