camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sathiyaraja <sathiyaraja1...@hotmail.com>
Subject ActiveMQ with replyto and replyTotype=Shared is not functioning for multiple queues call
Date Mon, 02 Nov 2015 14:26:47 GMT
Greetings All.,

  I'm stuck with issue with active mq while calling multiple replyTo type
queues. My request is flowing after Queue2. 

But if im not defining mq its failing with Timeouts sometime.

Help on this is much appreciated.

My Implementation:

<route id="route-1" streamCache="true">
<from uri="activemq:Queue1?replyToType=Shared&replyTo=Queue1Reply" />

<to uri:directRoute2/>
</route>

<route id="route-2" streamCache="true">
<from uri="uri:directRoute2" />
<to uri="activemq:Queue2?replyToType=Shared&replyTo=Queue2Reply" />
<choice>
<when>

<to uri="activemq:Queue3?replyToType=Shared&replyTo=Queue3Reply" />
</route>

<route id="route-4" streamCache="true">
<from uri="uri:directRoute4" />

<to uri="activemq:Queue4?replyToType=Shared&replyTo=Queue4Reply" />
</route>


My ActiveMQ bean definition:


<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	
	xsi:schemaLocation="
	   http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">

	 <bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="${broker.url}" />
		<property name="userName" value="${broker.userid}"/>
        <property name="password" value="${broker.password}"/>
        <property name="redeliveryPolicy" ref="redeliveryPolicy"/>
        <property name="watchTopicAdvisories" value="false"/>
	</bean> 
	
	
	<bean id="jmsTransactionManager"
		class="org.springframework.jms.connection.JmsTransactionManager">
		<property name="connectionFactory" ref="poolConnectionFactory" />
	</bean> 
	
	
	 <bean id="poolConnectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
		<property name="maxConnections" value="8" />
		<property name="connectionFactory" ref="jmsConnectionFactory" />
	</bean> 


	
	 <bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
		<property name="configuration" ref="jmsConfig"/>
        <property name="concurrentConsumers"
value="${activemq.concurrent.consumers}"/>
        <property name="requestTimeout" value="${activemq.request.timeout}"
/>
	</bean> 
	
	 <bean id="jmsConfig"
class="org.apache.camel.component.jms.JmsConfiguration">
		<property name="connectionFactory" ref="poolConnectionFactory" />
		<property name="transactionManager" ref="jmsTransactionManager" />
		<property name="transacted" value="true" />
		<property name="explicitQosEnabled" value="true"/>
		<property name="jmsMessageType" value="Text"/>
		<property name="disableTimeToLive" value="true" />	
	</bean>
	
	<bean id="redeliveryPolicy" class="org.apache.activemq.RedeliveryPolicy">
		<property name="maximumRedeliveries" value="2"/>  
	</bean>
</beans>


Regards.,
Sathiyaraja P




--
View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-with-replyto-and-replyTotype-Shared-is-not-functioning-for-multiple-queues-call-tp5773319.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message