Utilisation du cSplitter pour diviser un message et agréger les réponses des sous-messages

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 Bean Java, consultez le Guide d'utilisation de Studio Talend.

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;
	}
}