camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <>
Subject Re: Aggregator and closeCorrelationKeyOnCompletion
Date Thu, 18 Apr 2013 13:28:08 GMT
The key is only being added as closed when the aggreaged exchange has
been completed. So if the strategy throws an exception then its not
completed yet.

On Thu, Apr 18, 2013 at 12:25 PM, Sven Bauhan <> wrote:
> Hi,
> I use an aggregator to combine segmented messages (as the channel has
> limited size).
> For each received segment a response message is expected with the
> appropriate response status.
> As correlation key the message ID is used; and each segment has a segment
> number.
> When a complete message is received, the correlation key shall be closed to
> prevent receiving different messages with the same message ID.
> But what happens, if the message will not get completed, because a segment
> is incorrect? How can a correlation key be held open when the message is
> resend?
> I am not clear, how to implement the aggregate() method in the
> AggragationStrategy. How to react when a wrong segment is received? Does the
> Aggregator reset the correlation key and segment counter automatically, if
> the aggregate() method throws an exception? Or is there another way to tell
> the Aggregator what to do?
> Thanks,
> Sven

Claus Ibsen
Red Hat, Inc.
FuseSource is now part of Red Hat
Twitter: davsclaus
Author of Camel in Action:

View raw message