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

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

[Path] (パス)フィールドで、ソースファイルHello.txtがあるパスを入力または参照します。他のフィールドはデフォルト設定のままにします。

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

URISテーブルで、[+]ボタンをクリックして2行追加し、メッセージが送信されるエンドポイントのURIを指定します。このユースケースでは"direct:a"と"direct:b"です。

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

URIフィールドにエンドポイントURIを入力します。このユースケースでは"direct:a"です。

このステップを繰り返して、direct_bのエンドポイントURIを"direct:b"に設定します。

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

[Code] (コード)ボックスに、以下のコードを入力して、ソースメッセージをコンソールに出力します。

System.out.println("The source message is: " + exchange.getIn().getBody(String.class));

このステップを繰り返して、Monitor_endblock、Monitor_direct_a、Monitor_direct_bのコードを以下に示すようにカスタマイズして、各エンドポイントのメッセージを出力します。

Monitor_endblock:

System.out.println("The endblock message is: " + exchange.getIn().getBody(String.class));

Monitor_direct_a:

System.out.println("direct a just downloaded: "+exchange.getIn().getBody(String.class));

Monitor_direct_b:

System.out.println("direct b just downloaded: "+exchange.getIn().getBody(String.class));

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

[Language] (言語)リストでSIMPLEを選択します。

[Expression] (式)フィールドに新しいメッセージボディとして"New message"と入力します。

このステップを繰り返して、direct:aとdirect:bのメッセージボディをそれぞれ"message A"と"message B"に設定します。

[Ctrl] + [S]を押してジョブを保存します。

コンポーネントを設定 - Cloud - 8.0