Re: More ActiveMQ hotspots.. courtesy of continuous profiling :)

YourKit and JProfiler < http://www.ej-technologies.com/products/jprofiler/overview.html> are great commercial tools, and they have licenses for open source projects. On Tue, Jun 2, 2015 at 11:19 AM Kevin Burton wrote: > On Tue, Jun 2, 2015 at 6:16 AM, Tim Bain wrote:

Re: Cannot concurrently consume from embedded broker

Thank you! On Mon Feb 02 2015 at 9:06:40 PM Timothy Bish wrote: > > On 02/02/2015 05:59 PM, Thiago Kronig wrote: > > Timothy, last question, I promise. > > > > Prefetch = 1 means that at most 2 messages will be dispatched to a > > consumer, the in-flight message a

Re: Cannot concurrently consume from embedded broker

r = 2, and the other three consumers waiting for messages, as seen via MBean. On Mon Feb 02 2015 at 8:34:48 PM Timothy Bish wrote: > On 02/02/2015 05:27 PM, Thiago Kronig wrote: > > First of all, thank you Timothy and Tim for your time. > > > > In fact, setting jms.prefetch

Re: Cannot concurrently consume from embedded broker

02/2015 04:47 PM, Thiago Kronig wrote: > > I just tried the same approach using JMS consumers. No success. > > Source at: > > https://github.com/thiagokronig/activemq-camel- > test/blob/master/src/main/java/com/thiagokronig/activemqcameltest/ > ActiveMQJMSParallelTest.java

Re: Cannot concurrently consume from embedded broker

I just tried the same approach using JMS consumers. No success. Source at: https://github.com/thiagokronig/activemq-camel-test/blob/master/src/main/java/com/thiagokronig/activemqcameltest/ActiveMQJMSParallelTest.java On Mon Feb 02 2015 at 7:30:00 PM Thiago Kronig wrote: > Tim, you're

Re: Cannot concurrently consume from embedded broker

artup is supposed to work as quickly as your code > assumes? If not, you could increase the timeouts to 2 seconds, and I would > expect your test would start succeeding most/all of the time... > > On Mon, Feb 2, 2015 at 1:49 PM, Thiago Kronig > wrote: > > > Tim, othe

Re: Cannot concurrently consume from embedded broker

Tim, other thing: I tried to Thread.sleep(5000); between the producer commit and the consumer initialization, but had no success. On Mon Feb 02 2015 at 6:45:19 PM Thiago Kronig wrote: > Tim, in may scenario I want to consume N messages in N consumers, one for > each. My consumers wai

Re: Cannot concurrently consume from embedded broker

t; hit 0 by the end of your timeout interval? Based on what you've shows us > so far, this appears to be an artifact of your test code, not a problem > with the broker. > > On Mon, Feb 2, 2015 at 1:02 PM, Thiago Kronig > wrote: > > > Hi list. > > > > I&#

Cannot concurrently consume from embedded broker

Hi list. I'm trying to concurrently consume 10 messages sent to an embedded ActiveMQ broker over the VM transport. Sometimes my code works, sometimes it hangs at the n-th message, randomly. If I change to a JBossMQ, my Camel client works. Can someone help me in setting my ActiveMQ broker? Sourc