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

Federico Mariani reassigned CAMEL-25819:
----------------------------------------

    Assignee: Federico Mariani

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

Reply via email to