[
https://issues.apache.org/jira/browse/CAMEL-17582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen updated CAMEL-17582:
--------------------------------
Priority: Minor (was: Critical)
> Aggregation information lost in distributed environment
> --------------------------------------------------------
>
> Key: CAMEL-17582
> URL: https://issues.apache.org/jira/browse/CAMEL-17582
> Project: Camel
> Issue Type: Bug
> Components: came-core
> Affects Versions: 2.16.3
> Reporter: Vincent Broucke
> Priority: Minor
>
> We have a problem with an aggregation using the JdbcAggreationRepository in a
> distributed environment.
> The scenario when the problem occurs is the following : we have a route that
> aggregates two messages received from RabbitMQ, let's say message1 and
> message2. Sometimes, message1 arrives on machine1 and message2 on machine2.
> We observe that information contained in message1 is lost when message2 is
> persisted to the database. We think that problem comes from
> AggregateProcessor in doAggregation method. We suppose that the
> aggregateProcessor1 and aggregateProcessor2 get nothing from the database :
>
> {code:java}
> Exchange originalExchange =
> aggregationRepository.get(newExchange.getContext(), key);{code}
> Flow continues and aggregateProcessor1 wants to persist the exchange to the
> database using doAggregationRepositoryAdd methods :
>
>
> {code:java}
> doAggregationRepositoryAdd(newExchange.getContext(), key, originalExchange,
> answer);{code}
> When exchange is persisted, the aggregateProcessor2 wants also persists the
> exchange to the database but information contained in exchange1 will be lost
> because it uses the original exchange received from the database that was
> empty.
>
>
> Have you encountered this problem? Is it fixed in another version?
>
> Thank you,
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
