version : Mule 2.2.1
I'm trying to aggregate to messages and processes them them using some business logic ( first message needs to complete before I start processing other one)
I'm using custom-correlation-aggregator-router and have written custom aggregator, which extends AbstractEventAggregator . I have implemented aggregateEvents,createEventGroup,shouldAggregateEvents methods.. This setup works fine for first set of messages but after that none of the methods from this custom router class gets called.
What am I missing here ?
Thanks
-Prashant
- Configuration
<service name="InputAggregator">
<inbound>
<inbound-endpoint ref ="InAggregator" />
<custom-correlation-aggregator-router class="MyInboundAggregator" timeout="2000" failOnTimeout="true" >
</custom-correlation-aggregator-router>
</inbound>
