I think the problem is you need to send the response message on the consumer
side - i.e. add something like
.to( “jms://outputq <jms://outputq>” ) in the *Consumer side* route
> On Sep 7, 2016, at 9:28 PM, Venu_s <svsv...@gmail.com> wrote:
>
> Hello,
>
> I am using camel version 2.10.0.redhat-60024 ( the redhat version of the jar
> ) and jboss-a-mq-6.2.0.redhat-133 as my JMS provider and trying to do a
> simple request reply pattern with the following two routes
>
> *Producer side*
>
> from(endPointUrl).routeId("2")
> .setHeader("JMSExpiration",
> constant(System.currentTimeMillis() +
> 10000))
> .to(ExchangePattern.InOut,
> "jms:entityQueue?disableTimeToLive=true&requestTimeout=4000&replyTo=outputq")
> .log("After coming out of request resply") ;
>
> *Consumer side*
>
>
> from( "jms:entityQueue?disableTimeToLive=true").routeId("5")
>
> .log(">> Payload Received : ${body}")
>
> The behavior I am seeing seems to me that the producer side waits for 4s (
> requestTimeout = 4000 ), times out and then puts the message on the queue,
> which is picked up on the consumer side and then the reply is sent to the
> output queue when fails with no subscriber as the producer already timed
> out. I must be doing something wrong, been wrestling with it for a couple of
> days now. Any help is much appreciated. The full log below
>
> 22:26:50,024 INFO [org.apache.camel.processor.interceptor.Tracer]
> (http-localhost/127.0.0.1:8080-1)
> ID-DLS014MA4251185-57084-1473301230802-25-8 >>> (2)
> from(direct://processSoapEndPoint) --> log://body%20is%20$%7Bbody%7D <<<
> Pattern:InOnly,
> Headers:{breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7},
> BodyType:String, Body:venu
> 22:26:50,024 INFO [body is ${body}] (http-localhost/127.0.0.1:8080-1)
> Exchange[ExchangePattern:InOnly, BodyType:String, Body:venu]
> 22:26:50,025 INFO [org.apache.camel.processor.interceptor.Tracer]
> (http-localhost/127.0.0.1:8080-1)
> ID-DLS014MA4251185-57084-1473301230802-25-8 >>> (2)
> log://body%20is%20$%7Bbody%7D --> <<< Pattern:InOnly,
> Headers:{breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7},
> BodyType:String, Body:venu
> 22:26:50,025 INFO [org.apache.camel.processor.interceptor.Tracer]
> (http-localhost/127.0.0.1:8080-1)
> ID-DLS014MA4251185-57084-1473301230802-25-8 >>> (2) --> <<<
> Pattern:InOnly, Headers:{JMSExpiration=10000,
> breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7}, BodyType:String,
> Body:venu
> 22:26:50,026 INFO [org.apache.camel.processor.interceptor.Tracer]
> (http-localhost/127.0.0.1:8080-1)
> ID-DLS014MA4251185-57084-1473301230802-25-8 >>> (2) -->
> jms://entityQueue?disableTimeToLive=true&replyTo=outputq&requestTimeout=4000
> <<< Pattern:InOnly,
> Headers:{breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7,
> JMSExpiration=1473304794724}, BodyType:String, Body:venu
> 22:26:54,116 WARN
> [org.apache.camel.component.jms.reply.PersistentQueueReplyManager] (Camel
> (camel-26) thread #71 - JmsReplyManagerTimeoutChecker[outputq]) Timeout
> occurred after 4000 millis waiting for reply message with correlationID
> [Camel-ID-DLS014MA4251185-57084-1473301230802-25-9]. Setting
> ExchangeTimedOutException on (MessageId:
> ID-DLS014MA4251185-57084-1473301230802-25-7 on ExchangeId:
> ID-DLS014MA4251185-57084-1473301230802-25-8) and continue routing.
> 22:26:54,119 ERROR [org.apache.camel.processor.DefaultErrorHandler] (Camel
> (camel-26) thread #71 - JmsReplyManagerTimeoutChecker[outputq]) Failed
> delivery for (MessageId: ID-DLS014MA4251185-57084-1473301230802-25-7 on
> ExchangeId: ID-DLS014MA4251185-57084-1473301230802-25-8). Exhausted after
> delivery attempt: 1 caught: org.apache.camel.ExchangeTimedOutException: The
> OUT message was not received within: 4000 millis due reply message with
> correlationID: Camel-ID-DLS014MA4251185-57084-1473301230802-25-9 not
> received. Exchange[Message: venu]:
> org.apache.camel.ExchangeTimedOutException: The OUT message was not received
> within: 4000 millis due reply message with correlationID:
> Camel-ID-DLS014MA4251185-57084-1473301230802-25-9 not received.
> Exchange[Message: venu]
> at
> org.apache.camel.component.jms.reply.ReplyManagerSupport.processReply(ReplyManagerSupport.java:133)
> [camel-jms-2.10.0.redhat-60024.jar:2.10.0.redhat-60024]
> at
> org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler.onTimeout(TemporaryQueueReplyHandler.java:61)
> [camel-jms-2.10.0.redhat-60024.jar:2.10.0.redhat-60024]
> at
> org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:53)
> [camel-jms-2.10.0.redhat-60024.jar:2.10.0.redhat-60024]
> at
> org.apache.camel.component.jms.reply.CorrelationTimeoutMap.onEviction(CorrelationTimeoutMap.java:30)
> [camel-jms-2.10.0.redhat-60024.jar:2.10.0.redhat-60024]
> at
> org.apache.camel.support.DefaultTimeoutMap.purge(DefaultTimeoutMap.java:209)
> [camel-core-2.10.0.redhat-60024.jar:2.10.0.redhat-60024]
> at
> org.apache.camel.support.DefaultTimeoutMap.run(DefaultTimeoutMap.java:159)
> [camel-core-2.10.0.redhat-60024.jar:2.10.0.redhat-60024]
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> [rt.jar:1.7.0_55]
> at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
> [rt.jar:1.7.0_55]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
> [rt.jar:1.7.0_55]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> [rt.jar:1.7.0_55]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> [rt.jar:1.7.0_55]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> [rt.jar:1.7.0_55]
> at java.lang.Thread.run(Thread.java:745) [rt.jar:1.7.0_55]
>
> 22:26:54,180 INFO [org.apache.camel.processor.interceptor.Tracer] (Camel
> (camel-27) thread #69 - JmsConsumer[entityQueue])
> ID-DLS014MA4251185-57084-1473301230802-26-3 >>> (5)
> from(jms://entityQueue?disableTimeToLive=true) --> <<< Pattern:InOut,
> Headers:{JMSDeliveryMode=2, JMSPriority=4, JMSTimestamp=1473305210033,
> breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7,
> JMSReplyTo=queue://outputq, JMSDestination=queue://entityQueue,
> JMSMessageID=ID:DLS014MA4251185-57065-1473301202541-19:1:10:1:1,
> JMSType=null,
> JMSCorrelationID=Camel-ID-DLS014MA4251185-57084-1473301230802-25-9,
> JMSRedelivered=false, JMSXGroupID=null, JMSExpiration=0}, BodyType:String,
> Body:venu
> 22:26:54,182 INFO [org.apache.camel.processor.interceptor.Tracer] (Camel
> (camel-27) thread #69 - JmsConsumer[entityQueue])
> ID-DLS014MA4251185-57084-1473301230802-26-3 >>> (5) --> log[>> Payload
> Received : ${body}] <<< Pattern:InOut, Headers:{JMSDeliveryMode=2,
> JMSPriority=4, JMSTimestamp=1473305210033,
> breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7,
> JMSReplyTo=queue://outputq, JMSDestination=queue://entityQueue,
> JMSMessageID=ID:DLS014MA4251185-57065-1473301202541-19:1:10:1:1,
> JMSType=null,
> JMSCorrelationID=Camel-ID-DLS014MA4251185-57084-1473301230802-25-9,
> JMSRedelivered=false, JMSXGroupID=null, JMSExpiration=0}, BodyType:String,
> Body:venu
> 22:26:54,183 INFO [5] (Camel (camel-27) thread #69 -
> JmsConsumer[entityQueue]) >> Payload Received : venu
> 22:26:54,184 INFO [org.apache.camel.processor.interceptor.Tracer] (Camel
> (camel-27) thread #69 - JmsConsumer[entityQueue])
> ID-DLS014MA4251185-57084-1473301230802-26-3 >>> (5) log[>> Payload Received
> : ${body}] --> log[>> Payload Received Message: ${body}] <<< Pattern:InOut,
> Headers:{JMSDeliveryMode=2, JMSPriority=4, JMSTimestamp=1473305210033,
> breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7,
> JMSReplyTo=queue://outputq, JMSDestination=queue://entityQueue,
> JMSMessageID=ID:DLS014MA4251185-57065-1473301202541-19:1:10:1:1,
> JMSType=null,
> JMSCorrelationID=Camel-ID-DLS014MA4251185-57084-1473301230802-25-9,
> JMSRedelivered=false, JMSXGroupID=null, JMSExpiration=0}, BodyType:String,
> Body:venu
> 22:26:54,186 INFO [5] (Camel (camel-27) thread #69 -
> JmsConsumer[entityQueue]) >> Payload Received Message: venu
> 22:26:54,210 WARN
> [org.apache.camel.component.jms.reply.PersistentQueueReplyManager] (Camel
> (camel-26) thread #72 - PersistentQueueReplyManager[outputq]) Reply received
> for unknown correlationID
> [Camel-ID-DLS014MA4251185-57084-1473301230802-25-9]. The message will be
> ignored: ActiveMQTextMessage {commandId = 73, responseRequired = true,
> messageId = ID:DLS014MA4251185-57065-1473301202541-323:1:6:3:1,
> originalDestination = null, originalTransactionId = null, producerId =
> ID:DLS014MA4251185-57065-1473301202541-323:1:6:3, destination =
> queue://outputq, transactionId = null, expiration = 0, timestamp =
> 1473305214193, arrival = 0, brokerInTime = 1473305214194, brokerOutTime =
> 1473305214206, correlationId =
> Camel-ID-DLS014MA4251185-57084-1473301230802-25-9, replyTo =
> queue://outputq, persistent = true, type = null, priority = 4, groupID =
> null, groupSequence = 0, targetConsumerId = null, compressed = false, userID
> = null, content = org.apache.activemq.util.ByteSequence@52c34612,
> marshalledProperties = org.apache.activemq.util.ByteSequence@122d7231,
> dataStructure = null, redeliveryCounter = 0, size = 0, properties =
> {CamelJmsDeliveryMode=2,
> breadcrumbId=ID-DLS014MA4251185-57084-1473301230802-25-7},
> readOnlyProperties = true, readOnlyBody = true, droppable = false,
> jmsXGroupFirstForConsumer = false, text = venu}
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/JMS-message-with-Inout-pattern-tp5787336.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
