Hi,
I have a route similar to that below. I'm reading an XML file. The splitter
bean returns an Iterable<MyObj>. When the iterator next method is called, a
MyObj instance is created from the XML. The inner aggregator is correlating
object with the same id and once 10 MyObj are collected the proc process is
called. My problem is that the split completes and the afterSplitProc is
called before the inner aggregator finishes with any remaining MyObj. Is
there a way to stop the split from completing before the inner aggregation?
Any advice on a better approach would be appreciated as well.
v2.8.1
<camel:route>
<camel:from uri="file://c:/data?delay=666"></camel:from>
<camel:split streaming="true" strategyRef="sagg">
<camel:method bean="splitter" method="split"></camel:method>
<camel:aggregate id="myAgg" strategyRef="pagg"
completionSize="10"
completionTimeout="500">
<camel:correlationExpression>
<camel:simple>body.id</camel:simple>
</camel:correlationExpression>
<camel:process ref="proc"></camel:process>
</camel:aggregate>
</camel:split>
<camel:process ref="afterSplitProc"></camel:process>
</camel:route>
--
View this message in context:
http://camel.465427.n5.nabble.com/Splitter-with-inner-aggregator-tp5733899.html
Sent from the Camel - Users mailing list archive at Nabble.com.
