I'm using Active MQ 5.0 on a RedHat Linux system. I have a number of slow consumers in my network, but I cannot get the slow consumer policies to work.
I have set the PrefetchSize on the connection URL. java.naming.provider.url=tcp://localhost:61614?connectionTimeout=0&jms.prefetchPolicy.all=1000&jms.useCopyOnSend=false&jms.useCompression=true I have tried each of these: <constantPendingMessageLimitStrategy limit="0"/> <prefetchRatePendingMessageLimitStrategy multiplier="1"/> And have tried various values for the maximum pending limit in my code with this: ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy(); prefetchPolicy.setMaximumPendingMessageLimit(1000); ((ActiveMQConnection)this.connection).setPrefetchPolicy(prefetchPolicy); But in the JMX consoles, the entries for my subscribers show that PrefetchSize STARTs at 1000, and then it climbs from there, rather than remaining constant. On my slow consumers the DispatchedQueueSize grows until it is huge -- certainly way beyond any of the limits I have set. All the DiscardCounts are always 0. This in in my activemq.xml file: <!-- Destination specific policies using destination names or wildcards --> <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic="mpcs.>" producerFlowControl="false" memoryLimit="512mb"> <dispatchPolicy> <!-- <roundRobinDispatchPolicy/> --> <!-- <strictOrderDispatchPolicy/> --> <simpleDispatchPolicy/> </dispatchPolicy> <messageEvictionStrategy> <oldestMessageEvictionStrategy/> </messageEvictionStrategy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="0"/> <!-- <prefetchRatePendingMessageLimitStrategy multiplier="1"/> --> </pendingMessageLimitStrategy> <subscriptionRecoveryPolicy> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> Does this feature just not work? Does anyone know? -Marti DeMore -- View this message in context: http://www.nabble.com/Cannot-get-slow-consumers-to-discard-messages-tp20786422p20786422.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.