java - 如何停止 ActiveMQ 一段时间然后再次启动它？

Question

当我的输入主题中有 1000 条消息时，我想要一个 java 代码停止 ActiveMQ 5 分钟。然后在 5 分钟后再次启动它。

谢谢 ！

Answer 1

您可以启用 jmx 并使用 JMX api 连接到 activemq。抓住 borker 并对其调用停止操作。您也可以对特定队列执行相同的操作。

首先使用 jconsole 执行此操作。如果可行，请弄清楚如何使用 JMX api 做同样的事情。

http://activemq.apache.org/jmx.html

Answer 2

您可以在线程中运行侦听器，在收到 1000 条消息时暂停线程，而不是在超时后恢复线程。