Hi all,
I've finally solved setting AGGREGATION_COMPLETE_ALL_GROUPS to true in my
'signal' message.
Probably it would be a good idea moving it from the bottom of the
documentation into the parameters table so people may find it easily.
Ref: http://camel.apache.org/aggregator2.html
My two cents:
On Fri, Jun 6, 2014 at 5:01 PM, carlo cancellieri
wrote:
> Claus,
>
>> You get an invalid correlation key, so check that.
>>
>>
>>
>> aggrId
>>
>>
>
> Yes, I've added it to skip that error but the incoming (fake) exchange is
> still passed to the aggregation while what I need is to complete t
Claus,
> You get an invalid correlation key, so check that.
>
>
>
> aggrId
>
>
Yes, I've added it to skip that error but the incoming (fake) exchange is
still passed to the aggregation while what I need is to complete the
aggregation without this message.
It should be considered as a trigger
You get an invalid correlation key, so check that.
aggrId
Do you have that header
On Fri, Jun 6, 2014 at 4:37 PM, carlo cancellieri
wrote:
> Dear Claus,
> I'm trying to use the suggested flag eagerCheckCompletion="true" with no
> success.
> I still get:
> org.apache.camel.CamelExchangeEx
Dear Claus,
I'm trying to use the suggested flag eagerCheckCompletion="true" with no
success.
I still get:
org.apache.camel.CamelExchangeException: Invalid correlation key.
Exchange[test_complete.csv]
at
org.apache.camel.processor.aggregate.AggregateProcessor.doProcess(AggregateProcessor.java:204
Hi list,
I'm using the following aggregation:
aggrId
${in.header.complId} == 'END_${exchangeId}'
When the aggregation may be concluded I send an empty message with the
'complId' set to the expected value but currently I get:
org.apache.camel.CamelExchangeExcep
Hi
See the aggregator docs
http://camel.apache.org/aggregator2
there is an eagerCheckCompletion option
On Fri, Jun 6, 2014 at 2:46 PM, carlo cancellieri
wrote:
> Hi list,
> I'm using the following aggregation:
>
>
>
>
>
> aggregationRepositoryRef="aggregationRepository"
> completionFromB
Hi list,
I'm using the following aggregation:
aggrId
${in.header.complId} == 'END_${exchangeId}'
When the aggregation may be concluded I send an empty message with the
'complId' set to the expected value but currently I get:
org.apache.camel.CamelExchangeExce
