I am little bir confused here: as you posted "Twice the prefetch limit == slow consumer" But i have seen in the source code of activemq
(activemq-parent-5.8.0/activemq-client/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java) That prefetch limit default value for QUEUE is 1000 DURABLE TOPIC 100 NON DURBALE TOPIC is 32767 While 'constantPendingMessageLimitStrategy' is by default set to 1000. (activemq-parent-5.8.0/activemq-karaf-itest/src/test/resources/org/apache/activemq/karaf/itest/activemq.xml) So according to http://activemq.apache.org/slow-consumer-handling.html. --> In addition to the prefetch buffer for consumer, broker can also keep some messages in RAM for a consumer upto maximum limit : "constantPendingMessageLimitStrategy". Please correct me if i am wrong here ? ( Is twice the prefetch limit thing is valid for queues only ? ) Thanks, John -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-generate-slow-consumers-tp4672583p4672970.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
