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)