I have tried the following to achieve what I want. But I ran into some
errors:
My Route:
from("file:C:\\Users\\joe\\Desktop\\csv?noop=true").
unmarshal().csv().process(new
RefDataProcessor()).to("direct:Process");
from("file:C:\\Users\\joe\\Desktop\\csv2?noop=true").
unmarshal().csv().process(new
RefDataProcessor()).to("direct:Process");
from("direct:Process").aggregate(header("id"), new
RefDataAggregationStrategy()).completionTimeout(3000).to("direct:Processed");
The error that I get is the following:
[Users%5Cjoe%5CDesktop%5Ccsv] DefaultErrorHandler ERROR Failed
delivery for (MessageId: ID-HP10007131-52648-1363799287926-0-1 on
ExchangeId: ID-HP10007131-52648-1363799287926-0-3). Exhausted after delivery
attempt: 1 caught: org.apache.camel.CamelExchangeException: Invalid
correlation key. Exchange[null]
What should I understand from the invalid correlation key error message?
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Aggregator-Strategy-Question-tp5729337p5729546.html
Sent from the Camel - Users mailing list archive at Nabble.com.
