samples
from(sourceFtpUrl)//probably do archiving here?? .transacted("PROPAGATION_REQUIRED") .onCompletion() .onCompleteOnly() .log(LoggingLevel.INFO, getClass().getName(), "this part is consuming one csv file of many rows of records") .end() .unmarshal(bindy)//this is part to unmarshal to list of objects .split(body(), new SomeAggregator())//split the list, pass each bean to someBeanToProcessEachObject, then Aggregarte using SomeAggregator to aggregate each new object into old list .beanRef("someBeanToProcessEachObject", "process") .end() .split(body()).parallelProcessing() .beanRef("someProcess", "process")//Split again, which now each object is an already aggregrated object .end() .log(LoggingLevel.INFO, getClass().getName(), "All Processed");