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.
