From 2d8079d90c1d1da6010a41be9e19f78b8b750166 Mon Sep 17 00:00:00 2001 From: Iwein Fuld Date: Tue, 29 Dec 2009 20:17:53 +0000 Subject: [PATCH] INT-330: polished javadoc for MessageGroup --- .../integration/aggregator/MessageGroup.java | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageGroup.java b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageGroup.java index a62e7c492a..11d21d96dc 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageGroup.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageGroup.java @@ -9,10 +9,14 @@ import java.util.Collections; import java.util.List; /** - * Represents a group of correllated messages that is bound to a certain - * {@link org.springframework.integration.store.MessageStore}. The group can grow during its lifetime, if messages are - * added to it. According to its {@link org.springframework.integration.aggregator.CompletionStrategy} it - * can be complete depending on the messages in the group. + * Represents a group of correlated messages that is bound to a certain + * {@link org.springframework.integration.store.MessageStore} and correlation key. + * The group can grow during its lifetime, if messages are added to it. + *

+ * According to its {@link org.springframework.integration.aggregator.CompletionStrategy} it + * can be complete depending on the messages in the group. + *

+ * Listeners can be configured to get callbacks when (parts of) the group are processed or the whole group is completed. * * @author Iwein Fuld */ @@ -29,7 +33,7 @@ public class MessageGroup { this.completionStrategy = completionStrategy; this.correlationKey = correlationKey; this.messages.addAll(store.list(correlationKey)); - this.listeners = Collections.unmodifiableList(Arrays.asList(listeners)); + this.listeners = Collections.unmodifiableList(Arrays.asList(listeners)); } public boolean hasNoMessageSuperseding(Message message) {