[ 
https://issues.apache.org/jira/browse/CAMEL-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Federico Mariani resolved CAMEL-22659.
--------------------------------------
    Resolution: Fixed

> 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)

Reply via email to