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.

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