Community, I was working on slow consumer/producer blocked monitoring using JMX (yes, I know I can use advisory msgs, but they won't tell when slow consumer stops being slow consumer; also I want to get the big picture right away after monitor starts), and wrote a unit test to trigger slow consumer state situation. Like in many ActiveMQ unit tests, I used embedded broker , and also set prefetchSize as a small number so as to send less messages.
I observed that for all reasonably small prefetchSize numbers (with regard to nr. of messages I send quickly) slow consumer flag is being set. However, for prefetchSize=1 (which is still an async send, just consumer accepts no more than one message at a time) the flag is not raised. The unit test itself (prefetch size constant on top): https://github.com/art-licis/activemq-jmx-monitor/blob/master/src/main/java/today/jvm/amq/ActiveMQJmxMonitor.java Let me know and I can move this to ActiveMQ JIRA. - Art -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
