检测ActiveMQ流量控制

Question

我有一个生产系统，它使用ActiveMQ (5.3.2)将消息从服务器A发送到服务器B。几周前，系统莫名其妙地开始使用10+秒来发送消息。重新启动producer后，系统工作正常。

经过调查，我非常确定这是由于生产者流控制。(我有一个相当标准的activemq设置)。在此发生的前一天(由于其他原因)，我的消费者软件一直在不稳定地运行，甚至在一段时间内停止接受连接。所以我猜是这触发了这一切。(令我困惑的是，请求在一天后仍被抑制)。

问题--我如何确认请求正在被限制。我对服务器进行了堆转储--内存中是否有我可以查找的数据？

编辑:我在内存中找到了三个WireFormatNegotiator实例中的一个的WireFormatNegotiator.tcpNoDelayEnabled=false。我在试着找出这是怎么回事。

其次(也是更重要的)，有没有一种方法可以使用JMX来判断消息是否被限制了？我想设置一个Nagios警报，让我知道将来是否会发生这种情况。我应该用JMX检查什么属性？

Answer 1

您可以使用configure your producer client抛出javax.jms.ResourceAllocationException异常，然后可以检测/记录这些异常，等等，只需设置以下选项之一...

<systemUsage>
   <systemUsage sendFailIfNoSpaceAfterTimeout="3000">
   ...OR...   
   <systemUsage sendFailIfNoSpace="true">