メイン コンテンツをスキップする

cSplitterを使ってメッセージを分割し、サブメッセージからの返信を集約

このシナリオは、Talend ESBTalend Data Services PlatformTalend MDM PlatformTalend Real-Time Big Data PlatformTalend 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;
	}
}

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。