How to specify the method to call for an AggregationStrategy

davidferguson — Sat, 16 Nov 2024 06:32:45 GMT

Hi there,

I'm using various enterprise integration patterns that support exchange aggregation within Talend routes (e.g. Content-Enricher, Aggregator, Recipient-List and so on) and am able to create a bean that implements the AggregationStrategy interface just fine.

However, I was wondering how I would go about implementing a bean where I define multiple aggregate methods (with custom names) within the same bean. The use-case here is that I need to aggregate multiple times within a route and having to create separate beans each time is a bit silly. According to the documentation for poll enrich for example, I should be able somehow define a parameter called strategyMethodName to specify the aggregation strategy method name to use.

The problem is, I can't figure out how to do this in Talend as the Aggregation Strategy field in the cContentEnricher Talend component for example is hard-coded to create a new instance of my bean so I can't so something like:

...
.pollEnrich(
    "file:path/to/file/?fileName=some.file",
    3000,
    AggregationStrategies.bean(
        new beans.CustomAggregation(), "myCustomAggregationMethodName"
    )
)
...

Reference documentation for the AggregationStrategies.bean method here.

Does anyone know how to call a custom method name for aggregation in Talend? Maybe using cBean or cBeanRegister? I'm using Talend ESB 6.4.1

Thanks!

Re: How to specify the method to call for an AggregationStrategy

davidferguson — Thu, 21 Feb 2019 08:56:17 GMT

Bumpity-bump.

Re: How to specify the method to call for an AggregationStrategy

davidferguson — Thu, 21 Feb 2019 16:04:35 GMT

Ended up going with a cJavaDSLProcessor and implementing it myself. Not pretty, but it works.

topic Re: How to specify the method to call for an AggregationStrategy in Talend Studio

How to specify the method to call for an AggregationStrategy

Re: How to specify the method to call for an AggregationStrategy

Re: How to specify the method to call for an AggregationStrategy