Arne Bedürftig created CAMEL-22659:
--------------------------------------
Summary: Aggregator completionInterval not working during shutdown
Key: CAMEL-22659
URL: https://issues.apache.org/jira/browse/CAMEL-22659
Project: Camel
Issue Type: Bug
Affects Versions: 4.14.1
Reporter: Arne Bedürftig
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)
