如何在一定时间内停止ActiveMQ并再次启动它？

Question

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

谢谢！

Answer 1

您可以启用jmx并使用JMX API连接到activemq。抓住borker并调用停止操作。你也可以为特定的队列做同样的事情。

首先使用jconsole来做到这一点。如果它能解决如何使用JMX API做同样的事情。

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

Answer 2

可以在线程中运行监听，暂停线程，当你得到1000点的消息，比你可以超时后恢复线程。