Ce scénario s'applique uniquement à Talend ESB, Talend Data Services Platform, Talend MDM Platform, Talend Real-Time Big Data Platform et à Talend Data Fabric.
Pour plus de technologies supportées par Talend, consultez Composants Mediation de Talend.
Dans ce scénario, le composant cSplitter est utilisé pour diviser un message et agréger les réponses des sous-messages.
Un bean Java prédéfini, AppendAggregator est appelé comme stratégie pour agréger les réponses des sous-messages. Pour plus d'informations concernant la création et l'utilisation de Beans Java, consultez Utilisation des Beans.
package beans;
import org.apache.camel.Exchange;
import org.apache.camel.processor.aggregate.AggregationStrategy;
public class AppendAggregator implements AggregationStrategy {
public Exchange aggregate(Exchange oldEx, Exchange newEx) {
if(oldEx==null){
return newEx;
}
String oldBody = oldEx.getIn().getBody(String.class);
String newBody = newEx.getIn().getBody(String.class);
newEx.getIn().setBody(oldBody + "\n" + newBody);
return newEx;
}
}