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.