Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: softfail (nike.apache.org: transitioning domain of
 sandeepreddip@gmail.com does not designate 216.139.236.26 as permitted
 sender)
Date: Tue, 28 Oct 2014 05:29:18 -0700 (PDT)
From: sandp <sandeepreddip@gmail.com>
To: users@camel.apache.org
Message-ID: <1414499358832-5758215.post@n5.nabble.com>
Subject: camel-jms consumer 2.14.0 replyTo
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hi,
I'm trying to replyto a temporary HornetQ queue for every message produced
and consumed.

I send a message to a *queue *with exchange pattern as InOut on a timer
endpint. There is a *consumer with InOut pattern* for the queue that
consumes, processes the message and sends  it back to the same queue. What
I'm trying to do is to have a replyTo temporary queue for every message
produced and consumed.


Increasing the timeout is resulting in the same ExchangeTimedOutException as
well. I tried several ways but facing issues. I'm sure I'm missing something
fundamental. Appreciate a reply.


======Exception==========

org.apache.camel.ExchangeTimedOutException: The OUT message was not received
within: 20000 millis due reply message with correlationID: 

from("timer:foo?period=1200000000")
		.process(new CamelMessageProcessor())
		.to("direct:sendMessageToQueue")
		.end();
====Producer======
from("direct:sendMessageToQueue")
	
.to(*ExchangePattern.InOut*,"jms:queue:ctsCamelQueue?concurrentConsumers=5&timeToLive={{message.time.to.live}}")
		.end();

====Consumer======
from("jms:queue:ctsCamelQueue?transacted=false&requestTimeout=60000").setExchangePattern(ExchangePattern.InOut)
//some process
.to("direct:sendMessageToQueue")
end();


--
View this message in context: http://camel.465427.n5.nabble.com/camel-jms-consumer-2-14-0-replyTo-tp5758215.html
Sent from the Camel - Users mailing list archive at Nabble.com.