Strange, can you post the whole route file
Bilgin
On 23 July 2013 14:44, Jothi <codeintheo...@gmail.com> wrote:
> 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.
