手順
-
Sourceという名前のcFileコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
- [Path] (パス)フィールドで、入力ファイルパスを参照または入力します。このユースケースでは、指定されたファイルパスにHello World!というコンテンツを含むHello.txtファイルがあります。その他のパラメーターはそのままにしておきます。
-
cWireTapコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
-
URIフィールドに
"direct:a"
と入力して、ワイヤータップされたメッセージをこのエンドポイントにルーティングします。[Populate new exchange] (新しい交換を入力)チェックボックスをオンにして、入力タイプに[Processor] (プロセッサー)を選択し、[Code] (コード)ボックスに次のコードを入力して、ワイヤータップされたメッセージのファイル名およびそのコンテンツをコンソールに表示します。System.out.println("\nMessage wiretapped: "+ exchange.getIn().getHeader("CamelFileName")); System.out.println("Message content: "+ exchange.getIn().getBody(String.class)+"\n");
-
cJavaDSLProcessorコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
-
[Code] (コード)フィールドにJavaコード
.to("direct:b")
を入力して、元のメッセージのルーティング先とするエンドポイントのURIを定義します。 -
Endpoint_aという名前のcMessagingEndpointコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。URIフィールドに
"direct:a"
と入力して、このエンドポイントにルーティングされたメッセージを取得します。この操作を繰り返して、Endpoint_bのエンドポイントURIを設定します。 -
Monitor_aという名前のcProcessorコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。[Code] (コード)ボックスに次のコードを入力して、Endpoint_aにルーティングされるメッセージのファイル名を表示します。
System.out.println("Message on endpoint a: "+ exchange.getIn().getHeader("CamelFileName"));
- [Ctrl] + [S]を押してジョブを保存します。