<code>from("mysource") .unmarshal(new ListJacksonDataFormat(MyClass.class)) .split().body() .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { // process MyClass item exchange.getIn().setBody(processedItem); } }) .to("destinationForProcessedItem") .aggregate(new GroupedExchangeAggregationStrategy()) <== Seems like problem is here .process(new Processor() { // handle result of aggregation }) </code>

问题描述 投票：0回答：0