Hi,
I have done a migration of Camel and i use completionTimeOut for my
aggregates.
But i would prefer used CompletionSize, with a dynamic size which is
register with a split before.
from(TARIF_LISTE_SIMULATION).routeId(TARIF_LISTE_SIMULATION)
.bean(HeaderSetter.class, HeaderSetter.SET_ODEON_EXCHANGE_ID_HEADER)
.split(ExpressionBuilder.beanExpression(TarificationSimulationSpliter.class,
TarificationSimulationSpliter.SPLIT))
.parallelProcessing()
.bean(TarificationBean.class, TarificationBean.METHOD_NAME)
.aggregate(DefaultAggregationStrategy.getInstance()).header(UsefulConstants.ODEONEXCHANGEID)
.bean(VoidProcessor.class).completionTimeout(30000)
.end();
but i don't see how to use this and i looking for example.
regard's
Mathieu
--
View this message in context:
http://camel.465427.n5.nabble.com/completionSize-tp5653718p5653718.html
Sent from the Camel Development mailing list archive at Nabble.com.
