动态限制的一个说message queue与骆驼

Question

我是说骆驼新与特定场景在心中，我想首先，如果这是可能的，其次是否有人能提供一点点的方向。

基本上我需要执行的动态限制掉的队列。即设定的能力 在运行时 率的一个特别小组的信息将被消耗的队列。

所以我可能，例如，增加一个小组的消息可以消费在10每秒，另一组应在每1第二等。

我知道的基础设置了路线骆驼和信息分组上排队等，但只是不知道这一点从文档。

Answer 1

是的看起来像你正在寻找代理端节流，以避免消费者阻拦。

你有没有提出你在ActiveMQ的用户/ dev的论坛请求？

Answer 2

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

e.g。

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

Answer 3

你为什么不在Apache的骆驼JIRA添加RFE？

你有什么逻辑，用于确定对于给定的组消息？

的速率

如果不同组消息经过整个同一节流它可以得到复合物。它有点需要鉴别，以确定它属于并且因此其速率应通过与调节器，其基团的任何消息。

如果你需要一些时间来填写你的使用情况，并记录RFE我肯定骆驼社会，开发者可以提供帮助。

您可以尝试实现它自己。基本上什么是一个处理器，所以可以从做一个（ “ActiveMQ的：队列：foo” 的）处理（myOwnThrottler）。为了（ “豆：的handleMessage”）;

可以延长一些在骆驼类的： - DelegateProcessor - DelayProcessorSupport - 调节器

---

克劳斯易卜生 Apache的骆驼提交者

开源集成： http://fusesource.com 博客： http://davsclaus.blogspot.com/

Answer 4

好吧，我会奠定了方案进行更为详细的说明和突出主要拦截尽我所能告诉。

我有2个群体的消息(在现实的规模要大得多)，每一个不同的限制的要求-我们说，我指定这样的消息头作流量和flowTime.

• 第1组：流量=1;flowTime=60(每分钟1)
• 第2组：流量=1;flowTime=1 (1每秒)

我执行一个处理器，作为每 诞老人 其中探讨了头域，并使用他们，因为延迟器的输入。

我20000信息，从第1组和20000集团2

因为节流阀是消费者方面，延迟器被激活通过第1组将导致它成为缓慢，通过迅速填补其输入缓冲区和组2的消息然后将成为停留...即使我用多个队列为每 詹姆斯.

我意识到我可以组的消息使用JMXGroupID头和实施的多个消费者，但不认为会规模的要求对收容 n 小组。

什么我不知道，基本上，是否有任何方式做经纪人，而不是消费者方面的限制，或一些其他的解决方案，从而消费者可节流阀没有最终阻止。

希望我已经说明自己清楚，并感谢您的建议为止。