コンポーネントを設定

File_sourceという名前のcFileコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。

[Path] (パス)フィールドに入力ファイルパスを入力するか参照して、その他のパラメーターはそのままにしておきます。

このシナリオでは、指定されたディレクトリーに4つのテキストファイルがあります: a.txt、b.txt、c.txt、d.txt。これらのコンテンツはそれぞれ、This is a! 、This is b! 、This is c! 、This is d! です。

Aggregatorという名前のcAggregateコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。

[Language] (言語)フィールドで、式言語に[Constant] (定数)またはSimpleを選択します。

[Expression] (式)フィールドに式"getBody(String.class)"を入力して、メッセージのボディを取得します。

「戦略」フィールドに、作成したJava Bean AggregateBodyの 名前を入力します。

[Number of messages] (メッセージ数)チェックボックスをオンにして、フィールドに2を入力します。

Monitor_beforeという名前のcProcessorコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。

[Code] (コード)ボックスでコードを次のようにカスタマイズして、集計が実行される前に[Run] (実行)コンソールにメッセージのコンテンツが表示されるようにします。

System.out.println("Before aggregation: "+
exchange.getIn().getBody(String.class));

同様に、Monitor_afterという名前のcProcessorコンポーネントを設定して、集計が実行された後で[Run] (実行)コンソールにメッセージのコンテンツが表示されるようにします。

System.out.println("After aggregation: "+
exchange.getIn().getBody(String.class));

[Ctrl] + [S]を押してルートを保存します。

コンポーネントを設定 - 7.3