I just checked the changed log, we formally support Spring 3.0.x in Camel 2.7.0 and will set a default cached thread pool for consuming the JMS message.
Please try your test case with the latest Camel 2.8.3.

On Wed Dec 21 15:12:08 2011, Willem Jiang wrote:
Can you try the latest released Camel 2.8.3 ?
BTW, how about the message size ?

On Wed Dec 21 10:31:50 2011, LaSalle, Craig wrote:
Hi Camel Users -

I'm using:
Camel version 2.6.0
ActiveMQ version 5.5.0
Spring version 3.0.5.RELEASE

The problem:

I have a simple route that gets a message from a queue, and just outputs a trace statement. When I run a bunch of messages through the queue, several hundred work OK, then the messages get processed in chunks of 200. For example, there will be 800 messages pending in ActiveMQ, then a long pause, then 600 messages pending, then a long pause. The trace bean has then output 200 statements.

The long pause is the strange part. Of course, it kills the performance. Any thoughts on what could be causing the long pause? If I use ActiveMQ without Camel, it works fine.

Connection factory configuration ==>:

<bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL">
<value>failover:(tcp://localhost:61616)</value>
</property>
</bean>
</property>
<property name="maxConnections">
<value>100</value>
</property>
</bean>

Queue consumer endpoint definition ==>:

<endpoint id="subscriber.1.dequeue" uri="activemq:queue:mhub.subscriber.${subscriber.1.name}?concurrentConsumers=1&amp;maxConcurrentConsumers=15&amp;disableReplyTo=true"/>

Route reading from queue ==>:

<route id="subscriber.1" errorHandlerRef="myDeadLetterErrorHandler">
<from ref="subscriber.1.dequeue"/>
<to uri="bean:trace"/>
</route>

Trace bean ==>:

public class Trace implements Processor {
public void process(Exchange exchange) throws Exception {
System.out.println("trace: threadid: " + Thread.currentThread().getId());
}
}

Any help is greatly appreciated.

Thanks,
-Craig LaSalle

Craig LaSalle | Software Architect | Intuit Health Group | w.650-944-3022 | [email protected]








--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog:    http://willemjiang.blogspot.com (English)
        http://jnn.javaeye.com (Chinese)
Twitter: willemjiang Weibo: willemjiang

Reply via email to