diff --git a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageBarrier.java b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageBarrier.java index 402e4d2c10..b0907d98ff 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageBarrier.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageBarrier.java @@ -32,10 +32,16 @@ import org.springframework.integration.store.SimpleMessageStore; * {@link org.springframework.integration.aggregator.ReleaseStrategy#canRelease(org.springframework.integration.store.MessageGroup) canRelease(..)} * method). *
+ * This class differs from CorrelatingMessageHandler in that it completely decouples the receiver and the sender. It can + * be applied in scenarios where completion of a message group is not well defined but only a certain amount of messages + * for any given correlation key may be processed at a time. + * * The messages will be stored in a {@link org.springframework.integration.store.MessageGroupStore MessageStore} * for each correlation key. * * @author Iwein Fuld + * + * @see CorrelatingMessageHandler */ public class CorrelatingMessageBarrier extends AbstractMessageHandler implements MessageSource