From 886835b01cb3753d221837d6a58443fd6469335c Mon Sep 17 00:00:00 2001 From: Iwein Fuld Date: Thu, 24 Jun 2010 21:14:38 +0000 Subject: [PATCH] INT-1174: added javadoc describing the difference between CMB and CMH --- .../integration/aggregator/CorrelatingMessageBarrier.java | 6 ++++++ 1 file changed, 6 insertions(+) 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 { private static final Log log = LogFactory.getLog(CorrelatingMessageBarrier.class);