Do you have something listening on the direct endpoint? How do you have it configured? I see you've an extra colon in the endpoint uri here; Does the route consuming this direct endpoint also use "direct::Decoder" or just "direct:Decoder".
Are you using a single camel context? If you post the direct consumer route we'll be able to help you more. ste On Mon, Mar 8, 2010 at 2:27 PM, boday <[email protected]> wrote: > > 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. > >
