[
https://issues.apache.org/jira/browse/CAMEL-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017378#comment-14017378
]
Ben O'Day edited comment on CAMEL-7434 at 6/4/14 3:31 PM:
----------------------------------------------------------
[~sjavurek] - if we added forceCompletionOfGroup(key) on the AggregateProcessor
class, how would you invoke it externally?
I suppose we could add support for a new marker header
(AGGREGATION_COMPLETE_FOR_GROUP) and expect a groupKey as the body of the
message to force the completion...though this would still require an explicit
message be sent (vs. an API call)...is that what you are looking for?
was (Author: boday):
[~sjavurek] - if we added forceCompletionOfGroup(key) on the AggregateProcessor
class, how would you invoke it externally?
> Provide a way to force the completion of a aggregate exchange from an
> external event
> ------------------------------------------------------------------------------------
>
> Key: CAMEL-7434
> URL: https://issues.apache.org/jira/browse/CAMEL-7434
> Project: Camel
> Issue Type: New Feature
> Components: camel-core, eip
> Affects Versions: 2.13.0
> Reporter: Susan Javurek
> Assignee: Ben O'Day
> Fix For: Future
>
>
> There is a way to do this by creating a "trigger" exchange that is handled in
> a special way by the aggregation strategy and a completion predicate. But
> this solution is quite intrusive and painful to write.
> It would actually be much easier if the AggregateProcessor would implement
> and expose the following methods:
> public void forceCompletionOfGroup(String key)
> public Expression getCorrelationExpression()
> This way, it becomes possible to control "externally" an aggregator without
> having to implement some intrusive logic.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
