You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by madkak <ma...@gmail.com> on 2016/03/10 18:28:52 UTC

Camel kafka route - performance slowing down

Hi,

I have written camel Spring DSL route which consumes from JMS queue and
publishes it to a topic. This route is working fine in general but when
there is a consistent load for longer time, the route performance is slowing
down from ~6k msgs/min to ~600 msgs/min.

Below is my JMS configurations. Can you please help to keep the performance
consistent always.

	
	<bean id="wmqConnectionFactory1"
class="com.ibm.mq.jms.MQQueueConnectionFactory">
		<property name="CCDTURL" ref="urlobj1" />
		<property name="queueManager" value="${WMQ.queuemanager1}" />
	</bean>

	
	<bean id="cachingWmqConnectionFactory1"
		class="org.springframework.jms.connection.CachingConnectionFactory"
		destroy-method="destroy">
		<property name="targetConnectionFactory" ref="wmqConnectionFactory1" />
		<property name="cacheConsumers" value="true" />
		<property name="reconnectOnException" value="true" />
		<property name="sessionCacheSize" value="10" />
	</bean>

	
	<bean id="wmqTransactionManager1"
		class="org.springframework.jms.connection.JmsTransactionManager">
		<property name="connectionFactory" ref="wmqConnectionFactory1" />
	</bean>

	
	<bean id="wmq-qm1" class="org.apache.camel.component.jms.JmsComponent">
		<property name="connectionFactory" ref="cachingWmqConnectionFactory1" />
		<property name="transactionManager" ref="wmqTransactionManager1" />
		<property name="transacted" value="false" />
		<property name="cacheLevelName" value="CACHE_AUTO" />
		<property name="concurrentConsumers" value="10" />
		<property name="maxConcurrentConsumers" value="10" />
		<property name="maxMessagesPerTask" value="100" />
	</bean>



--
View this message in context: http://camel.465427.n5.nabble.com/Camel-kafka-route-performance-slowing-down-tp5778885.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel kafka route - performance slowing down

Posted by Willem Jiang <wi...@gmail.com>.
Hi,

It’s hard to tell what’s wrong from your information.
Can you set up the trace log[1] to fine out which part is slow?

[1]http://camel.apache.org/tracer.html

--  
Willem Jiang


Blog: http://willemjiang.blogspot.com (English)  
http://jnn.iteye.com (Chinese)
Twitter: willemjiang  
Weibo: 姜宁willem



On March 11, 2016 at 1:53:47 AM, madkak (madhumscis@gmail.com) wrote:
> Hi,
>  
> I have written camel Spring DSL route which consumes from JMS queue and
> publishes it to a topic. This route is working fine in general but when
> there is a consistent load for longer time, the route performance is slowing
> down from ~6k msgs/min to ~600 msgs/min.
>  
> Below is my JMS configurations. Can you please help to keep the performance
> consistent always.
>  
>  
> > class="com.ibm.mq.jms.MQQueueConnectionFactory">
>  
>  
>  
>  
>  
> > class="org.springframework.jms.connection.CachingConnectionFactory"
> destroy-method="destroy">
>  
>  
>  
>  
>  
>  
>  
> > class="org.springframework.jms.connection.JmsTransactionManager">
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
>  
> --
> View this message in context: http://camel.465427.n5.nabble.com/Camel-kafka-route-performance-slowing-down-tp5778885.html  
> Sent from the Camel - Users mailing list archive at Nabble.com.
>