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&amp;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.

Reply via email to