Sounds like the routes are started in wrong order.
You can try dicate the order.
http://camel.apache.org/configuring-route-startup-ordering-and-autostartup.html
On Tue, Jul 23, 2013 at 5:06 PM, Bilgin Ibryam <bibr...@gmail.com> wrote:
> 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.
--
Claus Ibsen
-----------------
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
