You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Mark <el...@gmail.com> on 2010/06/25 20:27:17 UTC
message routing help
I am trying to set up a simple Camel routing rule in ActiveMQ using
the example found online:
<route>
<from uri="activemq:example.A"/>
<to uri="activemq:example.B"/>
</route>
I have a message producer sending TextMessage objects to the example.A
queue and a listener that is listening on the example.B queue. I am
getting a bunch of exceptions in the ActiveMQ:
Caused by: org.apache.camel.ExchangeTimedOutException: The OUT message
was not received within: 20000 millis. Exchange[J
msMessage: ActiveMQTextMessage { MESSAGE INFORMATION }]
at org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265)
at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147)
at org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
at org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
at org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
at org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
at org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:93)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
at org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
at org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
at org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
at org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66)
at org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:84)
... 9 more
I am looking for what is the right way to use this EIP.