メイン コンテンツをスキップする 補完的コンテンツへスキップ

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

このタスクについて

メッセージを集約するために、集約戦略の構築に役立つ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.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を保存します。

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

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