No Consumer available Exception

[Jothi]

Camel Users,

I face a strange error when I tried to run one of my routes. Why I say
strange is because, I can see that the consumer for one of the routes is
started, but it still fails when run!

Here is the route;

        // Process and send to the aggregator
       
from(DIRECT_PROCESS_REF_DATA_ROUTER).convertBodyTo(String.class).log("in the
choice block!")
           
.setHeader(CORRELATION_HEADER_KEY).constant(CORRELATION_HEADER_VALUE)
            .choice()
               
.when().xpath(IRouterConstants.UNIT_MAPPING.getValue()).setHeader(IRouterConstants.EXCHANGE_HEADER_BU.getValue(),
simple("true"))
                    .convertBodyTo(MappingX.class)
                    .to(DIRECT_SEND_TO_AGGREGATOR)
               
.when().xpath(IRouterConstants.USER_MAPPING.getValue()).setHeader(IRouterConstants.EXCHANGE_HEADER_BU.getValue(),
simple("false"))
                    .convertBodyTo(MappingY.class)
                    .to(DIRECT_SEND_TO_AGGREGATOR)
                .otherwise()
                    .log(LoggingLevel.DEBUG, getClass().getName(), "Nothing
to do") // TODO... Nothing to do does not look nice
            //.endChoice()
        .routeId(ROUTE_ID_JAXB_TRANSFORMER);

        // Send to the Endur GO aggregator
       
from(DIRECT_SEND_TO_AGGREGATOR).setHeader(IRouterConstants.AGGREGATOR_FILE_COUNT.getValue()).constant(2)
           
.aggregate(header(CORRELATION_HEADER_KEY)).aggregationStrategyRef("mappingggregationStrategy").completionTimeout(3000)
            .convertBodyTo(String.class)
            .setHeader("CamelFileName").simple("${header.payloadFilename}")
            .to("file://{{ref.data.csv}}?readLock=rename")
        .routeId(ROUTE_ID_DATA_AGGREGATOR);

        // Read the files and send to the processor to convert the xml to
jaxb objects
        from("file://{{ref.data.staging}}")
            .routePolicy(goRoutePolicy).noAutoStartup()
            .to(DIRECT_PROCESS_REF_DATA_ROUTER)
        .routeId(ROUTE_ID_REF_DATA_ROUTER);

Here is the exception that I get:

org.apache.camel.CamelExchangeException: No consumers available on endpoint:
Endpoint[direct://processRefDataRouter].

The direct://processRefDataRouter is represented as a constant in the
DIRECT_PROCESS_REF_DATA_ROUTER in the class.



--
View this message in context: 
http://camel.465427.n5.nabble.com/No-Consumer-available-Exception-tp5736133.html
Sent from the Camel - Users mailing list archive at Nabble.com.