Message aggregator

NOTE: Version 1.0.0.M1 of Spring Integration Scala DSL only provides support for the default aggregation and release strategy with default attributes. Complete aggregator support (adequate to what's available via XML configuration) will be available in version 1.0.0.M2

EIP reference for Message Aggregator can be found here - http://eaipatterns.com/Aggregator.html

Continuation from Message Aggregator could be expressed using '-->' operator.

Message Aggregator

Root DSL element for Message Aggregator is aggregate

val aggregator = aggregate()

If you need to add any extra properties to the Message Aggregator you may do so using where method which accepts named parameters.

For example:

val aggregatorA = aggregate() where(name="myAggregator") //infix

val aggregatorB = aggregate().where(name="myAggregator") //infix

will produce a Message Aggregator named 'myAggregator'.

Properties that could be set:

name - component name

[Back to Core Messaging Patterns] (https://github.com/SpringSource/spring-integration-scala/wiki/Core-Messaging-Patterns)