You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/03/23 11:54:17 UTC
[5/5] camel git commit: CAMEL-7433: Allow aggregation strategy to
determine pre complete when using aggregator.
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 <da...@apache.org>
Authored: Mon Mar 23 10:36:31 2015 +0100
Committer: Claus Ibsen <da...@apache.org>
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 {
/**