cSplitterを使ってメッセージを分割し、サブメッセージからの返信を集約
このシナリオは、Talend ESB、Talend Data Services Platform、Talend MDM Platform、Talend Real-Time Big Data Platform、Talend Data Fabricにのみ適用されます。
このシナリオでは、cSplitterコンポーネントを使ってメッセージを分割し、サブメッセージからの返信を集約します。
事前定義されたJavaBeanであるAppendAggregatorは、サブメッセージからの応答を集約するための戦略として呼び出されます。JavaBeansの作成と使用については、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;
}
}