Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-330: polished javadoc for MessageGroup

Browse Source
This commit is contained in:
Iwein Fuld
2009-12-29 20:17:53 +00:00
parent 058e555de9
commit 2d8079d90c
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/MessageGroup.java
View File

@@ -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
* <code>add</code>ed 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 <code>add</code>ed to it.
* <p/>
* According to its {@link org.springframework.integration.aggregator.CompletionStrategy} it
* can be <i>complete</i> depending on the messages in the group.
* <p/>
* 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) {