diff --git a/docs/src/reference/docbook/aggregator.xml b/docs/src/reference/docbook/aggregator.xml
index 6ed365cb08..a4c7c9f528 100644
--- a/docs/src/reference/docbook/aggregator.xml
+++ b/docs/src/reference/docbook/aggregator.xml
@@ -407,8 +407,8 @@
A method defined on the bean referenced by
- correlation-strategy, that implements the
- correlation decision algorithm. Optional, with
+ correlation-strategy, that implements the
+ correlation decision algorithm. Optional, with
restrictions (requires correlation-strategy to be
present).
@@ -421,8 +421,8 @@
A method defined on the bean referenced by ref,
- that implements the message aggregation
- algorithm. Optional, depends on ref attribute being defined.
+ that implements the message aggregation
+ algorithm. Optional, depends on ref attribute being defined.
@@ -436,8 +436,8 @@
A method defined on the bean referenced by
- release-strategy, that implements the
- completion decision algorithm. Optional, with
+ release-strategy, that implements the
+ completion decision algorithm. Optional, with
restrictions (requires release-strategy to be
present).
@@ -550,6 +550,8 @@
The same expression-based approach could be applied when dealing with custom Release and
Correlation strategies.
+
+
Instead of defining a bean for custom CorrelationStrategy via correlation-strategy
attribute you can implement your simple correlation logic via SpEL expression and configure it via
correlation-strategy-ecpression attribute.
diff --git a/spring-integration-core/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd b/spring-integration-core/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd
index c9c58beaf6..e52c646cbd 100644
--- a/spring-integration-core/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd
+++ b/spring-integration-core/src/main/resources/org/springframework/integration/config/xml/spring-integration-2.0.xsd
@@ -2196,6 +2196,11 @@ Name of the header whose value to use.
+
+ A reference to a bean that implements the release strategy.
+ The bean can be an implementation of the
+ ReleaseStrategy interface or a POJO
+
@@ -2205,11 +2210,15 @@ Name of the header whose value to use.
+
+ A method defined on the bean referenced by release-strategy, that implements the completion
+ decision algorithm.
+
- An expression to apply to the message group
+ A SpEL expression to apply to the message group (e.g, payload.size() > 6)
@@ -2217,6 +2226,11 @@ Name of the header whose value to use.
+
+ A reference to a bean that implements the decision algorithm as to whether a given
+ message group is complete. The bean can be an implementation of the
+ CorrelationStrategy interface or a POJO.
+
@@ -2228,11 +2242,15 @@ Name of the header whose value to use.
+
+ A method defined on the bean referenced by correlation-strategy, that implements the
+ correlation decision algorithm
+
- An expression to apply to the message group
+ A SpEL expression to apply to the Message
@@ -2242,6 +2260,10 @@ Name of the header whose value to use.
+
+ The channel where the aggregator will send the messages that timed out (if send-partial-results-
+ on-expiry is 'false').
+
@@ -2265,7 +2287,14 @@ Name of the header whose value to use.
-
+
+
+
+ Tells if partially aggregated messages should be released when their storage time had expired (see
+ MessageGroupStore.expireMessageGroups(long))
+
+
+