The Aggregate Mediatormediator implements the Message Aggregator enterprise integration pattern and aggregates the response messages for messages that were split by the Clone or Iterate mediator and sent using the Send mediator. At the same time, it can aggregate messages in the presence of matching elements specified by the correlateOn
XPath expression. The Aggregate mediator collects the incoming messages until the the completion condition is satisfied. The completion condition can specify a minimum or maximum number of messages to be collected, or a timeout value in seconds, after which the aggregation terminates. Note that when the Iterate Mediatormediator is used to split the requests and produces only an n number of fragmented messages, the Aggregate Mediator mediator will terminate as soon as it receives n responses, even if you have specified a higher minimum limit.
...
Code Block | ||||
---|---|---|---|---|
| ||||
<outSequence> <aggregate> <onComplete expression="//m0:getQuoteResponse" xmlns:m0="http://services.samples"> <send/> </onComplete> </aggregate> </outSequence> |
In this example, the Mediator mediator aggregates the responses coming in to into the ESB, and on completion , it sends the aggregated message through the Send Mediatormediator.
For more examples, see:
- Sample 62: Routing a Message to a Dynamic List of Recipients and Aggregating Responses
- Sample 400: Message Splitting and Aggregating the Responses
- Sample 751: Message Split Aggregate Using Templates
...
hidden | true |
---|
...