CAMEL-7433: Allow aggregation strategy to determine pre complete when using aggregator.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3f965157 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3f965157 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3f965157 Branch: refs/heads/master Commit: 3f9651578007dd42c02f80b92ba5d5d84097b094 Parents: efaa7bf Author: Claus Ibsen <[email protected]> Authored: Mon Mar 23 10:36:31 2015 +0100 Committer: Claus Ibsen <[email protected]> Committed: Mon Mar 23 11:56:05 2015 +0100 ---------------------------------------------------------------------- .../aggregate/PreCompletionAwareAggregationStrategy.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3f965157/camel-core/src/main/java/org/apache/camel/processor/aggregate/PreCompletionAwareAggregationStrategy.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/processor/aggregate/PreCompletionAwareAggregationStrategy.java b/camel-core/src/main/java/org/apache/camel/processor/aggregate/PreCompletionAwareAggregationStrategy.java index 53fc3f0..c2734bf 100644 --- a/camel-core/src/main/java/org/apache/camel/processor/aggregate/PreCompletionAwareAggregationStrategy.java +++ b/camel-core/src/main/java/org/apache/camel/processor/aggregate/PreCompletionAwareAggregationStrategy.java @@ -18,6 +18,15 @@ package org.apache.camel.processor.aggregate; import org.apache.camel.Exchange; +/** + * A specialized {@link org.apache.camel.processor.aggregate.AggregationStrategy} which enables the aggregator to run + * in pre-completion mode. This allows the {@link #preComplete(org.apache.camel.Exchange, org.apache.camel.Exchange)} method + * to control the completion. Only completion timeout or interval can also be used; any other completion configuration + * is not in use. + * <p/> + * Using this strategy supports the use-case, where an incoming Exchange has information that may trigger the completion + * of the current group. And then use the new incoming Exchange to start a new group thereafter from scratch. + */ public interface PreCompletionAwareAggregationStrategy extends AggregationStrategy { /**
