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&maxConcurrentConsumers=15&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
