Re: Slow consumers not detected with ?consumer.prefetchSize=1

2017-08-31 Thread art.licis
Yep, for 2, 3, 4, ... (i.e., smaller than producer produces ahead); for 1 it doesn't work. In my test there's a constant at the beginning of a class, currently 2. Changing to 1 breaks the test. - Art -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Slow consumers not detected with ?consumer.prefetchSize=1

2017-08-31 Thread Tim Bain
Does it work for prefetchSize=2, just not 1? (Sorry, I won't be able to try running the code till sometime next week, otherwise I'd just try it myself rather than ask.) Tim On Thu, Aug 31, 2017 at 7:40 AM, art.licis wrote: > I'm sorry, I sent a wrong link; Unit test is here: > https://github.co

Re: Slow consumers not detected with ?consumer.prefetchSize=1

2017-08-31 Thread art.licis
I'm sorry, I sent a wrong link; Unit test is here: https://github.com/art-licis/activemq-jmx-monitor/blob/master/src/test/java/today/jvm/amq/ActiveMQJmxMonitorTest.java If you need a completely independent unit test, that's possible. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-

Slow consumers not detected with ?consumer.prefetchSize=1

2017-08-31 Thread art.licis
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 consume