ActiveMQ with replyto and replyTotype=Shared is not functioning for multiple queues call

[sathiyaraja <sa...@hotmail.com>]

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.