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)