Hi,

My route is quite simple:
from(REQUEST_QUEUE).process(processor1).process(processor2).process(processor3).to(COMPLETE_QUEUE)
REQUEST_QUEUE and COMPLETE_QUEUE are both activemq queues. It runs fine normaly. But when I restart activmq, I found my Camel application just exited with this log:

2014-01-29 15:23:02 WARN Camel (camel-1) thread #0 - JmsConsumer[queue.request] org.apache.camel.component.jms.DefaultJmsMessageListenerContainer - Setup of JMS message listener invoker failed for destination 'queue.request' - trying to recover. Cause: java.io.EOFException 2014-01-29 15:23:02 WARN Camel (camel-1) thread #2 - JmsConsumer[queue.complete] org.apache.camel.component.jms.DefaultJmsMessageListenerContainer - Setup of JMS message listener invoker failed for destination 'queue.complete' - trying to recover. Cause: java.io.EOFException 2014-01-29 15:23:02 ERROR Camel (camel-1) thread #2 - JmsConsumer[queue.complete] org.apache.camel.component.jms.DefaultJmsMessageListenerContainer - Could not refresh JMS Connection for destination 'queue.complete' - retrying in 5000 ms. Cause: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused. 2014-01-29 15:23:02 ERROR Camel (camel-1) thread #0 - JmsConsumer[queue.request] org.apache.camel.component.jms.DefaultJmsMessageListenerContainer - Could not refresh JMS Connection for destination 'queue.request' - retrying in 5000 ms. Cause: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused.

I tried to use failover broker url(failover:tcp://localhost:61616) but same thing happened. I also tried to use jms component instead of activemq component but still got the same result.

Reply via email to