I have a polling consumer setup to periodically (using camel-timer) retry
messages from an error queue.
like this...
//initialized in constructor of polling consumer
private static ProducerTemplate producer = context.createProducerTemplate();
...
Exchange exchange = consumer.receive("activemq:errorQueue", 100);
String msgBody = exchange.getIn().getBody(String.class);
producer.sendBody("direct::Decoder", msgBody);
Every now and then, I get the following warning in my logs...
WARN - DirectProducer - No consumers available on endpoint:
Endpoint[direct://Decoder]
Whenever this happens, the message being sent to this endpoint is lost!!! I
know the endpoint is active and started, so what would cause it to have "no
consumers available"?
Also, is there a way for my polling consumer to detect/handle this case so
that the message isn't lost and simply waits for an unavailable consumer to
become available?
thanks
-----
Ben - Senior Consultant
using SMX 3.3.1/Camel 2.1
--
View this message in context:
http://old.nabble.com/DirectProducer---no-consumers-available-on-endpoint...message-is-lost-tp27828628p27828628.html
Sent from the Camel - Users mailing list archive at Nabble.com.
