Hi, iam new to camel,Im trying to implement a synchronous request-reply mechanism using camel component. I have 2 wmq queues *1. requestQuee - application will send requests to this queue 2. responseQueue - application will have to listen & receive response from this queue *
/ <route id="jms-sync-route"> <camel:from uri="direct:jms" /> <camel:to uri="jms:queue:requestQuee?replyTo=queue:responseQueue&exchangePattern=InOut" /> </route> / / <camel:route id="mockresponse"> <camel:from uri="jms:queue:requestQuee?concurrentConsumers=5"/> <camel:process ref="jmsResponseListener" /> <camel:to uri="jms:queue:responseQueue"/> </camel:route>/ bean jmsResponseListener having logic public class MockResponseGenerator implements Processor{ / public void process(Exchange ex) throws Exception { ex.getIn().setBody("<res>mockresponse</res>"); String msgid=(String) ex.getIn().getHeader("JMSMessageID"); if(msgid != null){ ex.getIn().setHeader("JMSCorrelationID",msgid); } } }/ *I getting error as follows,it is observed that. message is en queued to requestQuee , but not de queued.* /Caused by: org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 20000 millis due reply message with correlationID: Camel-ID-ICB1864-58611-1463553066644-3-9 not received on destination: queue://responseQueue. Exchange[ID-ICB1864-58611-1463553066644-3-8][Message: <?xml version="1.0" encoding="UTF-8"?></ *If i remove inout pattern.message is en queued to requestQuee and after dequeed by mockresponse route ,eventually MockResponseGenerator prepares mock response and enqueued to responseQueue.* Please update your suggestions to achieve the same. Thanks :) -- View this message in context: http://camel.465427.n5.nabble.com/Camel-jms-In-Out-Pattern-tp5782730.html Sent from the Camel - Users mailing list archive at Nabble.com.