You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Ranjit Nethi (JIRA)" <ji...@apache.org> on 2016/10/25 15:23:59 UTC
[jira] [Created] (AMQ-6481) Producer Flow Control not disabling
Ranjit Nethi created AMQ-6481:
---------------------------------
Summary: Producer Flow Control not disabling
Key: AMQ-6481
URL: https://issues.apache.org/jira/browse/AMQ-6481
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.13.3
Environment: Active MQ 5.13.3 in Karaf 4.x
Camel 2.16.3
Centos OS
Reporter: Ranjit Nethi
Producer flow control cannot be disabled in activemq 5.13.3. I have tried to disable producer flow control using the following configurations for destination policy and system usage below.
I was able to recreate this issue easily by reducing the memory limit to very low value and send messages consistently (load test). Once the memory usage shows 100% on the activemq console. I can see the producer flow control kicks in with the following message in log:
Usage Manager memory limit reached 134217728. Producers will be throttled to the rate at which messages are removed from this destination to prevent flooding it. See http://activemq.apache.org/producer-flow-control.html for more info.
I can surely increase the memory limit, but that would only push the occurrence of the issue to later.
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" producerFlowControl="false">
<dispatchPolicy>
<strictOrderDispatchPolicy />
</dispatchPolicy>
<pendingSubscriberPolicy>
<fileCursor />
</pendingSubscriberPolicy>
<pendingDurableSubscriberPolicy>
<fileDurableSubscriberCursor />
</pendingDurableSubscriberPolicy>
</policyEntry>
</policyEntries>
<policyEntries>
<policyEntry queue=">" producerFlowControl="false">
<pendingQueuePolicy>
<fileQueueCursor />
</pendingQueuePolicy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="128 mb/>
</memoryUsage>
<storeUsage>
<storeUsage limit="3 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="1 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)