java - 如何停止 ActiveMQ 的“队列”以停止接收消息

Question

是否可以在 ActiveMQ 的特定队列消耗 100 条消息 5 秒后停止它，并在 5 秒后再次重新启动并开始接收消息？

Answer 1

ActiveMQ 有一些流量控制，但主要是内存限制。

尝试使用一些类似的路由器软件，例如Apache Camel Throttler

我不确定您是否可以完全按照您的要求进行开箱即用，但类似的事情。或者您可以通过一些逻辑添加您想要的内容。请注意，Camel捆绑在大多数 ActiveMQ 发行版中。

然后，您可能会设置一个“来自”队列，应用程序在其中写入消息，并通过 ActiveMQ 将其​​路由到消费者读取消息的“至”队列。