集約戦略としてJava Beanを作成する - 7.3

Aggregate (メディエーション)

Version
7.3
Language
日本語
Product
Talend Data Fabric
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Open Studio for ESB
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
ジョブデザインと開発 > サードパーティーシステム > ルーティングコンポーネント(メディエーション) > 集計コンポーネント(メディエーション)
データガバナンス > サードパーティーシステム > ルーティングコンポーネント(メディエーション) > 集計コンポーネント(メディエーション)
データクオリティとプレパレーション > サードパーティーシステム > ルーティングコンポーネント(メディエーション) > 集計コンポーネント(メディエーション)
Last publication date
2023-08-09

このタスクについて

メッセージを集約するために、集約戦略の構築に役立つJava Beanを使います。

手順

  1. リポジトリーツリービューで[Code] (コード)ノードを展開し、Beansノードを展開します。コンテキストメニューで[Create Bean] (Beanを作成)を選択します。
  2. [New Bean] (新規Bean)ウィザードが開きます。[Name] (名前)フィールドにBeanの名前(たとえばAggregateBody)を入力します。[Finish] (終了)をクリックし、ウィザードを閉じます。
  3. 次の図に示すようにコードを入力します。このユースケースでは、すべてのメッセージを1つのメッセージに集約します。
    package beans;
    
    import org.apache.camel.Exchange;
    import org.apache.camel.processor.aggregate.AggregationStrategy;
    
    public class AggregateBody 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+newBody);
    		return newEx;
    	}
    }
  4. [Ctrl]+[S]を押し、Beanを保存します。