Hi, we don't seem to be receiving messages on temp queues. The underlying
transport is Tibco EMS (JMS).
Below are snippets from the log regarding listener and publisher starting
up...
It looks all fine (to my eye..) besides the 'real' temp queue only being
mentioned on the sender side
(Queue[$TMP$.EMS-JUSD-FIANALYTICS1.61FE4D794D832E09.2]) but not on the
receiver. Can we not have matching temp queues by using the same logical
camel destinations?
Thanks!
Listener:
2011-03-11 14:48:35,515 DEBUG| org.apache.camel.impl.DefaultComponent |
createEndpoint | main | Creating endpoint
uri=[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff],
path=[temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff],
parameters=[{}]
2011-03-11 14:48:35,562 DEBUG| g.apache.camel.component.jms.JmsConsumer |
doStart | main | Starting consumer:
Consumer[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff]
2011-03-11 14:48:35,562 DEBUG| ore.bus.connector.camel.CamelContextImpl |
ResumeRouteConsumers | main | Route: route10 >>>
EventDrivenConsumerRoute[Endpoint[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff]
->
Instrumentation:route[UnitOfWork(Pipeline[[Channel[SetExchangePattern[InOnly]],
Channel[Pipeline[[Threads, Pipeline[[Channel[Delegate[null]],
Channel[sendTo(Endpoint[bean://esb_queue_dyna.Listener?method=process])],
Channel[SetExchangePattern[InOnly]]]]]]]]])]]
2011-03-11 14:48:35,640 INFO | ore.bus.connector.camel.CamelContextImpl |
ResumeRouteConsumers | main | Route: route10 started and
consuming from:
Endpoint[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff]
Publisher:
2011-03-11 14:48:36,265 DEBUG| org.apache.camel.impl.DefaultComponent |
createEndpoint | ad #12 - Threads | Creating endpoint
uri=[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff?disableReplyTo=true],
path=[temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff],
parameters=[{disableReplyTo=true}]
...
2011-03-11 14:48:36,281 DEBUG| org.apache.camel.processor.SendProcessor |
doInAsyncProducer | ad #15 - Threads | >>>>
Endpoint[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff?disableReplyTo=true]
Exchange[Message: <?xml version="1.0" encoding="UTF-8"
standalone="yes"?>esb_queue_dyna8418338e-ee10-4c46-90b0-50516f49aa65TestDynaResponse10.0.2.15<?xml
version="1.0" encoding="UTF-8" standalone="yes"?><ns2:TestDynaResponse
xmlns:ns2="http://com.nomura.fi.mbs/esb"/>test_service2011-03-11T14:48:36.281-05:00TestTestDynaResponse]
2011-03-11 14:48:36,296 DEBUG| nt.jms.JmsConfiguration$CamelJmsTemplate |
execute | ad #15 - Threads | Executing callback on JMS Session:
com.tibco.tibjms.TibjmsxSessionImp@c74fe
2011-03-11 14:48:36,343 DEBUG| g.apache.camel.component.jms.JmsProducer |
createMessage | ad #15 - Threads | ReplyTo is disabled on endpoint:
Endpoint[jms://temp:queue:Qtemp_test_service_10.0.2.15_fb403e11-592e-40bc-99ce-9fd25710caff?disableReplyTo=true]
2011-03-11 14:48:36,343 DEBUG| nt.jms.JmsConfiguration$CamelJmsTemplate |
doSend | ad #15 - Threads | Sending JMS message to:
Queue[$TMP$.EMS-JUSD-FIANALYTICS1.61FE4D794D832E09.2] with message:
TextMessage={ Header={ JMSMessageID={null} JMSDestination={null}
JMSReplyTo={null} JMSDeliveryMode={PERSISTENT} JMSRedelivered={false}
JMSCorrelationID={null} JMSType={null} JMSTimestamp={0} JMSExpiration={0}
JMSPriority={4} } Properties={ } Text={<?xml version="1.0" encoding="UTF-8"
standalone="yes"?>esb_queue_dyna8418338e-ee10-4c46-90b0-50516f49aa65TestDynaResponse10.0.2.15<?xml
version="1.0" encoding="UTF-8" standalone="yes"?><ns2:TestDynaResponse
xmlns:ns2="http://com.nomura.fi.mbs/esb"/>test_service2011-03-11T14:48:36.281-05:00TestTestDynaResponse}
}
--
View this message in context:
http://camel.465427.n5.nabble.com/Issue-with-JMS-Temp-Queues-Tibco-EMS-tp3425694p3425694.html
Sent from the Camel - Users mailing list archive at Nabble.com.
