camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sandp <sandeepred...@gmail.com>
Subject camel-jms consumer 2.14.0 replyTo
Date Tue, 28 Oct 2014 12:29:18 GMT
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.

Mime
View raw message