activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Oleg Dulin <>
Subject Slow consumer advisory never sent
Date Wed, 18 Sep 2013 10:41:40 GMT
Here are my policies:

					<policyEntry topic="X.>"
						producerFlowControl="false" prioritizedMessages="true">
					<policyEntry queue="Y"
						producerFlowControl="true" prioritizedMessages="true"
					<policyEntry topic="Z.>"
						producerFlowControl="false" advisoryForSlowConsumers="true">
						<!-- amq:slowConsumerStrategy>
						    <amq:abortSlowConsumerStrategy checkPeriod="1000"
						</amq:slowConsumerStrategy -->
								multiplier="1.5" />
					<policyEntry tempQueue="true" producerFlowControl="true"
						memoryLimit="10mb" advisoryForSlowConsumers="true" queuePrefetch="1024"
						expireMessagesPeriod="10000" gcInactiveDestinations="true">

I disguised the actual topics for confidentiality.

My test is this. I run the application and set a breakpoint in the 
consumer on Z.FOO.BAR and my expectation is that Z.> policy would kick 
in and after some time I get an advisory message on 
ActiveMQ.Advisory.SlowConsumers.Topic.Z.FOO.BAR -- but I don't.

The same test works with simple Java program….

What am I doing wrong ?

Oleg Dulin
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message