I was finally able to write unit test to replicate the problem without using Camel.
Here is the issue https://issues.apache.org/activemq/browse/AMQ-2565 On Mon, 2009-12-14 at 09:53 -0800, Dragisa Krsmanovic wrote: > On Mon, 2009-12-14 at 09:48 -0800, Dragisa Krsmanovic wrote: > > while ((exchange = consumerTemplate.receive(endpoint, 2000l)) != > > null) { > > > > result.append(exchange.getIn().getBody(String.class)).append('/'); > > } > > > To add more detail. This loop seems to read only one message at a time. > Even when there is multiple messages waiting. > > > -- Dragisa Krsmanovic Java Developer Public Library of Science http://www.plos.org