I am trying to use Multiple Aggregates on a single header wherein each of the aggregate picks up different fields from a header to do the aggregation. Once the aggregation is done and all are sent to the next component in the route, is there a way to figure out what aggregate came from which header evaluation. For example my route looks like. As you can see below i use multiple aggregates. Each aggregate actually uses a different "POLICY" field from the header. As these aggregates are sent to the next bean, how can i differentiate which one came from which header combination.
<from uri = "netty:tcp://localhost:1556?decoder=#xihMediationFrameDecoder&sync=false" /> <process ref="perProcessor" /> <to uri = "bean:perAdapterBean" /> <aggregate strategyRef="policyUsageAggregate" completionInterval="100000"> <correlationExpression> <simple>${in.headers.POLICYID_1}-${in.headers.Tier}-${in.headers.ENTITLEMENT_1}-${in.headers.ENTITLEMENT_2}-${in.headers.VERSION}-${in.headers.RAT_ID}</simple> </correlationExpression> <to uri = "bean:kpiWriterBean" /> </aggregate> <aggregate strategyRef="policyUsageAggregate" completionInterval="100000"> <correlationExpression> <simple>${in.headers.POLICYID_2}-${in.headers.Tier}-${in.headers.ENTITLEMENT_1}-${in.headers.ENTITLEMENT_2}-${in.headers.VERSION}-${in.headers.RAT_ID}</simple> </correlationExpression> <to uri = "bean:kpiWriterBean" /> </aggregate> <aggregate strategyRef="policyUsageAggregate" completionInterval="100000"> <correlationExpression> <simple>${in.headers.POLICYID_3}-${in.headers.Tier}-${in.headers.ENTITLEMENT_1}-${in.headers.ENTITLEMENT_2}-${in.headers.VERSION}-${in.headers.RAT_ID}</simple> </correlationExpression> <to uri = "bean:kpiWriterBean" /> </aggregate> -- View this message in context: http://camel.465427.n5.nabble.com/Aggregation-EIP-tp5610860p5610860.html Sent from the Camel - Users mailing list archive at Nabble.com.