You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Federico Mariani (Jira)" <ji...@apache.org> on 2026/10/19 13:47:00 UTC
[jira] [Updated] (CAMEL-25819) camel-core - Aggregate EIP does not recover exchanges when the KeyValueRepository is auto-discovered
[ https://issues.apache.org/jira/browse/CAMEL-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Federico Mariani updated CAMEL-25819:
-------------------------------------
Fix Version/s: 4.24.0
> camel-core - Aggregate EIP does not recover exchanges when the KeyValueRepository is auto-discovered
> ----------------------------------------------------------------------------------------------------
>
> Key: CAMEL-25819
> URL: https://issues.apache.org/jira/browse/CAMEL-25819
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 4.23.0
> Reporter: Federico Mariani
> Assignee: Federico Mariani
> Priority: Minor
> Fix For: 4.24.0
>
>
> When an aggregator has no repository configured, {{AggregateProcessor.doStart()}} auto-discovers a single {{KeyValueRepository}} from the registry (CAMEL-24463) and assigns {{new KeyValueAggregationRepository(kvRepo)}} directly to the field. The {{isRecoverableRepository}} flag is only set in {{setAggregationRepository()}}, so it stays {{false}}.
> As a result, for an auto-discovered repository:
> * the recover checker is never scheduled
> * an aggregated exchange that fails downstream is never redelivered
> * its {{completed:<exchangeId>}} entry stays in the {{KeyValueRepository}} forever
> The same {{KeyValueAggregationRepository}} set explicitly with {{aggregationRepository(...)}} recovers as expected.
> Fix: use {{setAggregationRepository(...)}} in {{doStart()}}.
> _Claude Code on behalf of Federico Mariani_
--
This message was sent by Atlassian Jira
(v8.20.10#820010)