java - 无法停止ActiveMQ Producer？

Question

我无法停止 ActiveMQ Producer。

场景是:我为内存使用和临时存储设置了较低的值。

<systemUsage>
  <systemUsage>
    <memoryUsage>
      <memoryUsage limit="1 mb" />
    </memoryUsage>
    <storeUsage>
      <storeUsage limit="100 gb" />
    </storeUsage>
    <tempUsage>
      <tempUsage limit="50 mb" />
    </tempUsage>
  </systemUsage>
</systemUsage>

生产者流量控制设置为 false

<destinationPolicy>
  <policyMap>
    <policyEntries>
      <policyEntry topic=">" producerFlowControl="false"/>
    </policyEntries>
    <policyEntries>
      <policyEntry queue=">" producerFlowControl="false"/>
    </policyEntries>
  </policyMap>
</destinationPolicy>

现在经纪人已经阻止了生产者并且无法阻止生产者，为什么会发生这种情况？

经纪商日志显示:

停止生产者(ID:隐藏)以防止淹没queue://test.queue.0。请参阅http://activemq.apache.org/producer-flow-control.html了解更多信息(阻塞时间:151 秒)

Answer 1

您尚未禁用队列的 ProducerFlowControl，仅适用于主题。

您需要添加如下内容:

<policyEntry queue=">" producerFlowControl="false"/>

日志提供的链接非常详细地解释了该行为。您的生产者不知何故淹没了经纪人，经纪人通过阻塞一段时间来做出响应。