Thank's for the hint Claus! It's works for me!
Here is the code maybe it serves to someone else:
>From my context.xml
<setHeader headerName="aggregation_parameter">
<simple>${file:name.noext}</simple>
</setHeader>
<choice>
<when>
<simple>${headers.CamelFileNameOnly} not contains '.suffix'
</simple>
<aggregate strategyRef="aggregatorStrategy"
completionSize="2">
<correlationExpression>
<simple>header[aggregation_parameter]</simple>
</correlationExpression>
<completionPredicate>
<simple>${headers.aggregation_done} !=
null</simple>
</completionPredicate>
<to uri="direct:aggregated" />
</aggregate>
</when>
<otherwise>
<to uri="direct:aggregated" />
</otherwise>
</choice>
Then in Java I've created an AggregatorStrategyProcessor where I have
implemented the logic of the aggregation.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Ftp-and-InputStream-body-tp5740774p5740822.html
Sent from the Camel - Users mailing list archive at Nabble.com.
