[
https://issues.apache.org/jira/browse/CAMEL-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18035588#comment-18035588
]
Federico Mariani commented on CAMEL-22659:
------------------------------------------
Thanks [~arneb] for reporting this.
You are correct, if completeAllOnStop and completionInterval are set, the
expectation is that the aggregation will complete on stop (due to
completionInterval).
> Aggregator completionInterval not working during shutdown
> ---------------------------------------------------------
>
> Key: CAMEL-22659
> URL: https://issues.apache.org/jira/browse/CAMEL-22659
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 4.14.1
> Reporter: Arne Bedürftig
> Assignee: Federico Mariani
> Priority: Minor
> Fix For: 4.14.3, 4.17.0
>
>
> Hello
>
> I am working with Apache Camel 4.14.1. I have a direct input and I am using a
> GroupedBodyAggregationStrategy and two different aggregateKeys.
>
> .aggregate(new GroupedBodyAggregationStrategy())
> .simple("${in.header.aggregateKey}")
> .completionSize(10)
> .completionInterval(5000)
> .completeAllOnStop()
>
> My observation is that the aggregate will not complete on shutdown (if I
> don't reach the completionSize). My camel.main.shutdown-timeout property is
> 5x the completionInterval.
>
> If I swap to completionTimeout it works, but that might not suit my use-case.
> I am also aware of forceCompletionOnStop and that will mitigate the issue,
> but I am not sure if this should be used as a default.
>
> I am I missing some configuration for the completionInterval to work or am I
> using it wrong?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
