King!
Glad you figured it out
I tried it but for me it didn’t work, it still produces one exchange per
“group” not one List with all grouped messages in it…
Quite tricky, this one is…
M
> On 8 Apr 2020, at 12:23, Craig Taylor wrote:
>
> Problem solved. To be a good net-zitizen, this is wh
Problem solved. To be a good net-zitizen, this is what I found after
finding some old source code from when I knew camel better:
Using .
aggregate( simple( "${body.id}"),
AggregationStrategies.flexible().accumulateInCollection( ArrayList.class))
.completionTimeout(5000L)
allowed me to have
I too have migrated to Camel 3 and I can’t get this to work.
I have tried using a constant(true) but I get only 1 message back instead of 3
Using a unique correlation expression I get as before, 3 different back, not a
List of 3
M
> On 4 Apr 2020, at 16:10, Craig Taylor wrote:
>
>>> Are you
>> Are you really sure as its supposed to store a List that are
the message body.
Yes, wanting to accumulate List over a period of time so before
passing into a "full changes" object so that batching of the request to a
3rd party api can occur.
I'm using Camel 3.1.0, and more detail / output from
Claus (or any other ), please correct me if I’m wrong but
all the GroupedAggregationStrategies extends AbstractListAggregationStrategy
and by inheritance aggregate() is called on the extended class if not provided
by own class.
This method in Camel 2.25.0 is only returning the Exchange (old/new o
Hi
Here is an unit test that tests it groups the body as a List
https://github.com/apache/camel/commit/f000201a1d0200fa8b9e596a516a84acb85dc538
On Sat, Apr 4, 2020 at 9:50 AM Claus Ibsen wrote:
>
> Hi
>
> Are you really sure as its supposed to store a List that are
> the message body.
> But ther
Hi
Are you really sure as its supposed to store a List that are
the message body.
But there are however only one unit test for this in camel-jms, so
lets add one to camel-core.
On Fri, Apr 3, 2020 at 11:23 PM Craig Taylor wrote:
>
> I'm wanting to accumulate all exchanges matching a correlation
Been struggling with this for a while and I have studied the underlying code
and found that “GroupedAggregationStrategies" extends
AbstractListAggreationStrategy which in turn uses the aggregate() method.
But it is not returning anything of value. It picks up a List internally but
then ignores
I'm wanting to accumulate all exchanges matching a correlation expression
(id) into a list for a given period of time. I've looked at the
GroupedBodyAggregationStrategy and it returns an Exchange with a body of
List's where I had expect an Exchange with a body of
List back.
aggregate(simple("${bo
