Red Hat CodeReady Studio を開きます。

CodeReady Studio を初めて起動すると、JBoss パースペクティブで開きます。

それ以外の場合は、以前の CodeReady Studio セッションで使用していたパースペクティブで開きます。

メニューから File → New → Fuse Integration Project を選択し、New Fuse Integration Project ウィザードを開きます。

Project Name フィールドに ZooOrderApp を入力します。

Use default workspace location オプションをチェックしたままにします。

Next をクリックし、Select a Target Runtime ページを開きます。

Karaf/Fuse on Karaf を選択して、ランタイムに None selected を受け入れます。

デフォルトの Apache Camel バージョン を受け入れます。

Next をクリックして Advanced Project Setup ページを開き、Empty - Blueprint DSL テンプレートを選択します。

Finish をクリックします。

Fuse Tooling は、プロジェクトをビルドするのに必要なすべてのファイルを Maven レポジトリーからダウンロードし始め、新しいプロジェクトを Project Explorer ビューに追加します。

CodeReady Studio で Fuse Integration パースペクティブが表示されていない場合は、すぐに切り替えるかどうかを尋ねられます。

Yes をクリックします。

Fuse Integration パースペクティブに、新しい ZooOrderApp プロジェクトが開きます。

ZooOrderApp プロジェクトに は、以下を含むルートを作成して実行するために必要なすべてのファイルが含まれます。

メインのルーティングコンテキストを表示するには、Editor ビューで blueprint.xml ファイルを開き、Source タブをクリックします。

Editor の設定ページを開きます。

Use ID values for all component labels オプションをチェックします。

CodeReady Studio の Project Explorer ビューで、テストメッセージを含めるフォルダーを作成します。

こちら をクリックして、提供される Tooling チュートリアルのリソース Fuse-tooling-tutorials-jbds-10.3.zip ファイルの場所に対して Web ブラウザーを開きます。

Fuse-tooling-tutorials-jbds-10.3.zip ファイルを、ZooOrderApp プロジェクトのワークスペースの外部にある便利な場所にダウンロードし、展開します。「1章Fuse Tooling のチュートリアルについて」で説明されているように、フォルダーが 2 つ含まれます。

messages フォルダーから、6 つの XML ファイルを ZooOrderApp プロジェクトの src/data フォルダーにコピーします。

Source タブをクリックします。

Editor ビューで XML ファイルが開きます。

たとえば、message1.xml ファイルの内容には、Brooklyn 動物園からの 12 頭のウォンバットに関する注文が表示されます。

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

Palette 'sComponents drawer から File コンポーネント( )をキャンバスにドラッグし、Route_route1 コンテナーノードでドロップします。

File コンポーネントは、Route_route1 コンテナーノード内の From _from1 ノードに変更されます。

キャンバスで From _from1 ノードを選択します。

キャンバスの下の Properties ビューには、編集用にノードのプロパティーフィールドが表示されます。

メッセージファイルのソースディレクトリーを指定するには、Properties ビューで Advanced タブをクリックします。

Directory Name フィールドに src/data を入力します。

src/data は、プロジェクトのディレクトリーからの相対パスです。

Consumer タブで、Noop オプションにチェックを入れて有効にします。

Noop オプションにより、message#.xml ファイルが src/data フォルダーから削除されなくなり、べき等を有効にして各 message#.xml ファイルが 1 度だけ消費されるようにします。

Details タブを選択して、ファイルノードの Details ページを開きます。

このツールは、Uri フィールドに、Advanced タブで設定した Directory Name および Noop プロパティーを自動的に設定することに注意してください。また、Id フィールドに自動生成される ID (_from1) も設定します。

自動生成される ID はそのまま残します。

別の File コンポーネントをPalette の Components ドロワーからドラッグし、それを Route_route1 コンテナーノードにドロップします。

File コンポーネントは、Route_route1 コンテナーノード内の To_to1 ノードに変更されます。

キャンバスで To_to1 ノードを選択します。

キャンバスの下の Properties ビューには、編集用にノードのプロパティーフィールドが表示されます。

Details タブで以下の操作を行います。

Route_route1 コンテナーで From _from1 ノードを選択し、To_Received ノードからコネクター矢印( )をドラッグし、解放します。

キャンバスの下部にある Source タブをクリックして、ルートの XML を表示します。

<?xml version="1.0" encoding="UTF-8"?>

<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

    <camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <to id="_Received" uri="file:target/messages/received"/>
        </route>
    </camelContext>
</blueprint>

以下のいずれか:

Project Explorer で ZooOrderApp/Camel Contexts/blueprint.xml を選択します。

blueprint.xml を右クリックし、Run As → Local Camel Context (without tests) を選択します。

Console パネルが開き、プロジェクトの実行の進捗を反映するログメッセージが表示されます。開始時に、Maven はローカルの Maven リポジトリーを更新するために必要なリソースをダウンロードします。Maven のダウンロードプロセスには数分かかる場合があります。

出力の最後に (以下のような) メッセージが表示されるまで待ちます。これらのメッセージは、ルートが正常に実行されたことを示しています。

...
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Route: _route1 started and consuming from:Endpoint[file://src/data?noop=true]
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Total 1 routes, of which 1 are started.
[Blueprint Event Dispatcher: 1]BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.163 seconds
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.918 seconds

Project Explorer で target/messages/ フォルダーを見つけ、これを展開し、target/messages/received フォルダーに 6 つのメッセージファイル (message1.xml から message6.xml) が含まれることを確認します。

message1.xml をダブルクリックして、ルートエディターの Design タブでそれを開き、Source タブを選択して XML コードを表示します。

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

Palette で Routing ドロワーを開き、Choice ( ) パターンをクリックし、（Design キャンバスで） From_from1 ノードをクリックします。

Route_route1 コンテナーが展開され、Choice_choice1 ノードが追加されます。エラーアイコンは、Choice_choice1 ノードに子ノードが必要なことを示しています。子ノードは、次のステップで追加します。

ルーティングドロワーから When ( )パターンをクリックし、キャンバスで Choice_choice1 ノードをクリックします。

Choice_choice1 コンテナーが展開され、When_when1 ノードが追加されます。

を When_when1 ノードを切り離すると、必要な 1 つ以上の必須プロパティー値が設定される必要があることを示します。

キャンバスで When_when1 ノードを選択し、Properties ビューでそのプロパティーを開きます。

テストメッセージは XML で記述されているため、xpath (XML クエリー言語用) を選択します。

インデントされた Expression フィールドに /order/orderline/quantity/text() > 10 と入力します。

この式は、quantity フィールドの値が 10 より大きいメッセージのみがルート内のこのパスを (invalidOrders フォルダーに) 移動することを指定します。

残りのプロパティーはそれぞれそのままにしておきます。

Source タブをクリックして、ルートの XML を表示します。

キャンバスで When_when1 ノードをクリックします。

When_when1 コンテナーが展開され、Log_log1 ノードが追加されます。

Message フィールドに The quantity requested exceeds the maximum allowed - contact customer. と入力します。

キャンバスで Log_log1 ノードをクリックします。

When_when1 コンテナーが展開され、SetHeader_setHeader1 ノードが追加されます。

キャンバスで SetHeader_setHeader1 ノードを選択し、Properties ビューでそのプロパティーを開きます。

残りのプロパティーはそのままにしておきます。

キャンバスで SetHeader_setHeader1 ノードをクリックします。

When_when1 コンテナーが展開され、To_to1 ノードが追加されます。

キャンバスで To_to1 ノードを選択し、Properties ビューでそのプロパティーを開きます。

Details タブで、directoryName を Uri フィールドの target/messages/invalidOrders に置き換え、Id フィールドに _Invalid と入力します。

Source タブをクリックして、ルートの XML を表示します。

キャンバスで Choice_choice1 コンテナーをクリックします。

Choice_choice1 コンテナーが展開され、Otherwise_otherwise1 ノードが追加されます。

Id フィールドで、_otherwise1 を _elseValid に変更します。

キャンバスで Otherwise_elseValid ノードをクリックします。

Otherwise-elseValid コンテナーが展開され、Log_log2 ノードが追加されます。

Message フィールドに This is a valid order - OK to process. と入力します。

残りのプロパティーはそのままにしておきます。

キャンバスで Log_log2 ノードをクリックします。

Otherwise_elseValid コンテナーが展開され、SetHeader_setHeader2 ノードが追加されます。

注記

多数のダイアグラムが表示されるようになったら、コンテナーを折りたたんでスペースを作ることができます。これを行うには、折りたたむコンテナーを選択し、その ボタンをクリックします。

コンテナーを再度開き、これを選択してから ボタンをクリックします。

Design タブでコンテナーを折りたたんだり展開したりしても、ルーティングコンテキストファイルには影響がありません。変更されないままです。

残りのプロパティーはそのままにしておきます。

キャンバスで SetHeader_setHeader2 ノードをクリックします。

Otherwise_elseValid コンテナーが展開され、To_to1 ノードが追加されます。

URI フィールドの directoryName を target/messages/validOrders に置き換え、Id フィールドに _Valid と入力します。

ルーティングコンテキストファイルを 保存 します。

設定の完了したコンテンツベースルーターは、以下のようになります。

キャンバスの左下にある Source タブをクリックして、ルートの XML を表示します。

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

<camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <choice id="_choice1">
                <when id="_when1">
                    <xpath>/order/orderline/quantity/text() &gt; 10</xpath>
                    <log id="_log1" message="The quantity requested exceeds the maximum allowed - contact customer."/>
                    <setHeader headerName="Destination" id="_setHeader1">
                        <constant>Invalid</constant>
                    </setHeader>
                    <to id="_Invalid" uri="file:target/messages/invalidOrders"/>
                </when>
                <otherwise id="_elseValid">
                    <log id="_log2" message="This is a valid order - OK to process."/>
                    <setHeader headerName="Destination" id="_setHeader2">
                        <constant>ReadyForDispatcher</constant>
                    </setHeader>
                    <to id="_Valid" uri="file:target/messages/validOrders"/>
                </otherwise>
            </choice>
        </route>
    </camelContext>
</blueprint>

プロジェクトの root ノード (ZooOrderApp) で、target/messages/ フォルダーを見つけて展開します。

target/messages/invalidOrders フォルダーに message1.xml および message3.xml が含まれていることを確認します。

これらのメッセージでは、quantity 要素の値は 10 を超えます。

target/messages/validOrders フォルダーに有効な注文が含まれる 4 つのメッセージファイルが含まれていることを確認します。

キャンバスで Route_route1 コンテナーの右をクリックします。

キャンバスで Route パターンが Route_route2 コンテナーノードになります。

キャンバスで Route_route2 コンテナーをクリックします。

Route_route2 コンテナーが拡張し、Direct コンポーネント (From_from2 ノード) が追加されます。

Uri フィールドの name (direct: の後) を OrderFulfillment に置き換え、Id フィールドに _direct:OrderFulfillment と入力します。

キャンバスで From _direct:OrderFulfillment ノードをクリックします。

Route_route2 コンテナーが展開され、Choice_choice2 ノードが追加されます。

Properties ビューで、Choice_choice2 ノードのプロパティーをそのままにしておきます。

キャンバスで Choice_choice2 ノードをクリックします。

Choice_choice2 コンテナーが展開され、When_when2 ノードが追加されます。

When_when2 ノードのプロパティーを以下のように設定します。

キャンバスで When_when/usa コンテナーをクリックします。

When_when/usa コンテナーが展開され、To_to1 ノードが追加されます。

Properties ビューで、以下を実行します。

キャンバスで When_when/usa ノードをクリックします。

When_when/usa コンテナーが展開され、SetHeader_setHeader3 ノードが追加されます。

ノードのプロパティーを以下のように設定します。

キャンバスで SetHeader ノードの上をクリックします。

When_when/usa コンテナーが展開され、Log_log3 ノードが追加されます。

キャンバスで Log_log3 ノードを選択し、Properties ビューでそのプロパティーを開きます。

Properties ビューで、以下を実行します。

ファイルを 保存 します。

Route_route2 の USA ブランチは以下のようになります。

キャンバスで Choice_choice2 コンテナーをクリックします。

Choice_choice2 コンテナーが展開され、Otherwise_otherwise1 ノードが追加されます。

キャンバスで Otherwise_else/ger ノードをクリックします。

Otherwise_else/ger コンテナーが展開され、SetHeader_setHeader3 ノードが追加されます。

Properties ビューで、以下を実行します。

キャンバスで SetHeader_setHead_ger ノードの下をクリックします。

Otherwise_else/ger コンテナーが展開され、Log_log3 ノードが追加されます。必要に応じて、Log_log3 ノードから SetHeader_setHead_ger ノードにコネクターエラーをドラッグします。

Properties ビューで、以下を実行します。

Components コーダーで File パターン( )を選択し、Log_ger ノードの下にクリックします。

Otherwise_else/ger コンテナーが展開され、To_to1 ノードが追加されます。必要に応じて、SetHeader_setHead_ger ノードから To_to1 ノードにコネクターエラーをドラッグします。

Properties ビューで、以下を実行します。

コンソールの出力の最後を確認します。以下の行が表示されるはずです。

ターゲットの宛先フォルダーを確認し、ルートが適切に実行されたことを確認します。

キャンバスで Choice_choice1 ノードを選択し、その アイコンをクリックして無条件ブレークポイントを設定します。

以下の Route_Route1 ノードに無条件ブレークポイントを設定します。

以下の Route_Route2 ノードに無条件ブレークポイントを設定します。

最初のブレークポイント _choice1 in _route1 [blueprint.xml] で停止した message1 の場合、変数 NodeId および RouteId (Exchange カテゴリー内) ならびに MessageBody および CamelFileName (Message カテゴリー内) をウォッチリストに追加します。

4 つの変数それぞれについて、以下を実行します。

変数 Destination を監視リストに追加します。

Expressions ビューに以下の変数が含まれているはずです。

MessageBody を右クリックしてコンテキストメニューを開き、Change Value を選択します。

(これを無効な注文から有効な注文に変更するため)、quantity の値を 15 から 10 に変更します。

この操作により、インメモリーの値のみが変更されます (message3.xml ファイルは編集されません)。

Expressions ビューに切り替え、MessageBody 変数を選択します。

変数リストの下にあるペインには message3 のボディー全体が表示され、注文アイテムの現在の値を簡単に確認することができます。

をクリックして、次のブレークポイントをステップします。

To_Invalid につながるブランチに従う代わりに、message3 が To_Fulfill および Route_route2 につながるブランチに従うようになりました。

Breakpoints ビューに切り替え、_choice1 の下に一覧表示されるブレークポイントの横にある各チェックボックスのチェックを外します。ブレークポイントのチェックボックスをクリアすると、一時的に無効になります。

をクリックして、次のブレークポイントをステップします。

デバッガーは、無効なブレークポイントをスキップし、_FulFill in _route1 [blueprint.xml] に移動します。

を再度クリックして次のブレークポイントをステップします。

デバッガーは _GER in _route2 [blueprint.xml] へジャンプします。

ツールバーで をクリックし、Camel デバッガーを終了します。

ZooOrderApp/target/messages/ ディレクトリーを展開して、メッセージが想定どおりに配信されたかどうかを確認します。

message1 のみが invalidOrders に送信され、message3.xml が validOrders/Germany フォルダーに表示されていることが確認できるはずです。

ツールバーの右側にある ボタンをクリックしてから、一覧から Fuse Integration を選択します。

デフォルトのレイアウトで Fuse Integration パースペクティブが開きます。

JMX Navigator タブを右端の Terminal タブにドラッグし、そこにドロップします。

この配置により、Diagram View がルーティングコンテキストのノードをグラフィカルに表示するスペースが多くなり、メッセージがルーティングコンテキストを移動する際にたどるパスを視覚的にトレースするのが容易になります。

注記

ルーティングコンテキストの .xml ファイルへのアクセスを容易にするために (特にプロジェクトが複数のコンテキストで構成される場合)、このツールは Project Explorer の Camel Contexts フォルダーにコンテキストを一覧表示します。

また、ルーティングコンテキストのすべてのルートは、そのコンテキストファイルエントリーのすぐ下にアイコンとして表示されます。キャンバスにルーティングコンテキストの 1 つのルートを表示するには、Project Explorer でそのアイコンをダブルクリックします。ルーティングコンテキストのすべてのルートを表示するには、コンテキストファイルエントリーをダブルクリックします。

Run As → Local Camel Context (without tests) を選択します。

JMX Navigator で、Local Processes を展開します。

ルートの要素を展開します。

Routes ノードを右クリックし、Start Tracing を選択します。

ツールは、Diagram View でルーティングコンテキストのグラフィカル表示を表示します。

すべてのメッセージフローパスを明確に表示するには、Diagram View タブで適切にフィットするようにノードをドラッグして、ノードを再配置する必要があります。また、Diagram View タブが拡張できるように、Red Hat CodeReady Studio の他のビューおよびタブのサイズを調整しなければならない場合もあります。

Project Explorer で ZooOrderApp/src/data を展開し、メッセージファイル (message1.xml から message6.xml) にアクセスできるようにします。

message1.xml をドラッグし、JMX Navigator の _context1>Endpoints>file>src/data?noop=true ノードにドロップします。

メッセージがルートを移動するにつれ、ツールがトレースし、各ステップでの経過を記録します。

パネルのメニューバーの アイコンをクリックし、Configure Columns を選択して Configure Columns ウィザードを開きます。

項目を選択または選択解除して、Messages View に項目を追加または除外することができます。選択した個々の項目を強調表示し、リストで上下に移動することで、Messages View で項目が表示される列の順番を再編成できます。

Configure Columns ウィザードで、このように列を選択して順序付けします。

これらの列とその順序は、列を変更するまで Messages View で維持されます。

Messages View で （更新ボタン）をクリックし、ビューに message2.xml メッセージトレースを設定します。

JMX Navigator にメッセージをドロップするたびに、Messages View を更新して、メッセージトレースを反映させる必要があります。

メッセージトレースのいずれかをクリックし、Properties ビューでその詳細を表示します。

ツールは、Properties ビューの上半分にメッセージトレースの詳細 (設定されている場合はメッセージヘッダーを含む) を表示し、Properties ビューの下半分にメッセージインスタンスの内容を表示します。そのため、アプリケーションがルート内の任意のステップでヘッダーを設定した場合、Message Details を確認して、想定通りに設定されたかどうかを確認することができます。

各インスタンスを強調表示し、特定のメッセージがどのようにルートを移動したかや、ルートの各ステップで期待したとおりに処理されたかどうかを調べて、メッセージインスタンス全体を確認することができます。

Diagram View を開いて、ルート内の関連付けられたステップが強調表示されていることを確認します。

ツールは、ルートを Diagram View に表示し、処理のステップを終了するパスをタイミングおよびパフォーマンスメトリクス (ミリ秒単位) にタグ付けします。ダイアグラムには、メトリクス Total exchanges だけが表示されます。

表示されるメトリクスにマウスポインターをかざして、メッセージフローに関する追加のメトリクスを表示します。

任意で、トレースが有効であれば、いつでも ZooOrderApp/src/data/ の残りのメッセージを JMX Navigator の _context1>Endpoints>file>src/data?noop=true ノードにドラッグし、ドロップすることができます。

後続のドロップごとに、 （更新ボタン） をクリックし、新しいメッセージトレースでメッセージビューを設定するのを忘れないでください。

完了時には、以下を実行します。

このチュートリアルを開始するには、以下のいずれかによる ZooOrderApp プロジェクトが必要です。

Project Explorer で、ZooOrderApp プロジェクトの /src/data/ ディレクトリーおよび /target/messages/ サブディレクトリーからトレースにより生成されたメッセージを削除します。トレースにより生成されたメッセージは、ID- 接頭辞で始まります。たとえば、図9.1「トレースにより生成されたメッセージ」には、8 つのトレースにより生成されたメッセージが表示されています。

図9.1 トレースにより生成されたメッセージ

すべてのトレースにより生成されたメッセージをバッチで選択し、右クリックしてから Delete を選択します。

New Folder ダイアログで、プロジェクトツリーペインで ZooOrderApp ノードを展開し、src フォルダーを選択します。

ZooOrderApp/src が Enter or select the parent folder フィールドに表示されるのを確認してください。

Folder name に /test/java を入力します。

Finish をクリックします。

Project Explorer では、src/main/resources フォルダーの下に新しい src/test/java フォルダーが表示されます。

新しい /src/test/java フォルダーがビルドパスに含まれていることを確認します。

右クリックして New → Camel Test Case の順に選択します。

test フィールド下の Camel XML ファイルで をクリックし、XML ファイルをフィルタリングするように設定されたファイルエクスプローラーを開き、ZooOrderApp プロジェクトの blueprint.xml ファイルを選択します。

OK をクリックします。Name フィールドは、デフォルトで BlueprintXmlTest に設定されます。

Next をクリックして Test Endpoints ページを開きます。

デフォルトでは、すべてのエンドポイントが選択され、テストケースに含まれます。

Finish をクリックします。

Project Explorer で ZooOrderApp プロジェクトを展開し、BlueprintXmlTest.java ファイルを表示します。

太字テキストの 2 行を追加します。最初の行を追加するとエラーが発生しますが、次のセクションで指示どおりに pom.xml ファイルを更新すると解決されます。

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.File;

これらの行の sisu-CallbackImpl protected Object[] expectedBodies={ …​…​ expectedBody2</something>"}; secretKeyRef-ClientAuth は、以下の protected String body#; 行に置き換えます。

protected String body1; protected String body2; protected String body3; protected String body4; protected String body5; protected String body6;

public void testCamelRoute() throws Exception { 行まで下方向にスクロールし、以下の行の body# = FileUtils.readFileToString(new File("src/data/message#.xml"), "UTF-8"); 行の後に直接挿入します。これらの行は、次のセクションで指示どおりに pom.xml ファイルを更新するまでエラーを示します。

// Valid orders body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8"); body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8"); body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8"); body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8"); // Invalid orders body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8"); body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

outputEndpoint.expectedBodiesReceivedInAnyOrder(expectedBodies); で始まり、...inputEndpoint.sendBody(expectedBody); } で終わるコードのブロックを、ここに示す行に置き換えます。

// Invalid orders outputEndpoint.expectedBodiesReceived(body1, body3); // Valid orders for USA output3Endpoint.expectedBodiesReceived(body2, body5, body6); // Valid order for Germany output4Endpoint.expectedBodiesReceived(body4);

残りのコードはそのまま残します。

更新された BlueprintXmlTest.java ファイルに必要な変更が反映されていることを確認します。以下のようになるはずです。

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.file;

public class BlueprintXmlTest extends CamelBlueprintTestSupport {

	// TODO Create test message bodies that work for the route(s) being tested
	// Expected message bodies
	protected String body1;
	protected String body2;
	protected String body3;
	protected String body4;
	protected String body5;
	protected String body6;
	// Templates to send to input endpoints
	@Produce(uri = "file:src/data?noop=true")
	protected ProducerTemplate inputEndpoint;
	@Produce(uri = "direct:OrderFulfillment")
	protected ProducerTemplate input2Endpoint;
	// Mock endpoints used to consume messages from the output endpoints and then perform assertions
	@EndpointInject(uri = "mock:output")
	protected MockEndpoint outputEndpoint;
	@EndpointInject(uri = "mock:output2")
	protected MockEndpoint output2Endpoint;
	@EndpointInject(uri = "mock:output3")
	protected MockEndpoint output3Endpoint;
	@EndpointInject(uri = "mock:output4")
	protected MockEndpoint output4Endpoint;

	@Test
	public void testCamelRoute() throws Exception {
		// Create routes from the output endpoints to our mock endpoints so we can assert expectations
		context.addRoutes(new RouteBuilder() {
			@Override
			public void configure() throws Exception {
				// Valid orders
				body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8");
				body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8");
				body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8");
				body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8");

				// Invalid orders
				body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8");
				body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

				from("file:target/messages/invalidOrders").to(outputEndpoint);
				from("file:target/messages/validOrders/USA").to(output3Endpoint);
				from("file:target/messages/validOrders/Germany").to(output4Endpoint);
				from("direct:OrderFulfillment").to(output2Endpoint);
			}
		});

		// Define some expectations

		// TODO Ensure expectations make sense for the route(s) we're testing
		// Invalid orders
		outputEndpoint.expectedBodiesReceived(body1, body3);

		// Valid orders for USA
		output3Endpoint.expectedBodiesReceived(body2, body5, body6);

		// Valid order for Germany
		output4Endpoint.expectedBodiesReceived(body4);

		// Validate our expectations
		assertMockEndpointsSatisfied();
	}

	@Override
	protected String getBlueprintDescriptor() {
		return "OSGI-INF/blueprint/blueprint.xml";
	}

}

<dependencies> セクションの最後に以下の行を追加します。

<dependency>
       <groupId>commons-io</groupId>
       <artifactId>commons-io</artifactId>
       <version>2.5</version>
       <scope>test</scope>
</dependency>

Run As → JUnit Test を選択します。

デフォルトでは、JUnit ビューがサイドバーで開きます (より見易くするには、Console、Servers、および Properties タブが表示される右下のパネルにドラッグします)。

テストが正常に実行されると、以下のような結果が表示されます。

図9.2 正常な JUnit の実行

テストに失敗すると、以下のような結果が表示されます。

図9.3 失敗した JUnit の実行

出力を確認し、テストの失敗を解決するアクションを実行します。

JUnit パネルに表示されるエラーの詳細を表示するには、パネルのメニューバーの をクリックして、ビューを最大化します。

JUnit テストケースを再度実行する前に、Project Explorer で ZooOrderApp プロジェクトの /src/data フォルダーから JUnit が生成するテストメッセージを削除します (図9.1「トレースにより生成されたメッセージ」を参照)。

No servers are available. このリンクをクリックして新規の server…​ リンクをクリックして、Define a New Server ページを開きます。

Red Hat JBoss Middleware ノードを展開して、利用可能なサーバーオプションを表示します。

Server’s host name および Server name のデフォルト値 (それぞれ localhost および Fuse n.n Runtime Server) を受け入れ、Next をクリックして Runtime ページを開きます。

Execution Environment の横にあるドロップダウンメニューからランタイム JRE を選択します。

JavaSE-1.8 (推奨) を選択します。必要に応じて、Environments ボタンをクリックしてリストから選択します。

Next をクリックして Fuse Server のランタイム定義を保存し、Fuse server configuration details ページを開きます。

SSH Port のデフォルト (8101) を受け入れます。

ランタイムは SSH ポートを使用して、サーバーの Karaf シェルに接続します。このデフォルトが正しくない場合は、Red Hat Fuse installDir/etc/org.apache.karaf.shell.cfg ファイルを確認して正しいポート番号を検出できます。

User Name に、サーバーへのログインに使用される名前を入力します。

これは、Red Hat Fuse installDir/etc/users.properties ファイルに保存されているユーザー名です。

設定されていない場合は、user=password,role のフォーマットを使用してそのファイルにユーザーを追加するか (例: joe=secret,Administrator)、karaf jaas コマンドセットを使用して設定できます。

Password に、User name がサーバーにログインするのに必要なパスワードを入力します。

これは、Red Hat Fuse の installDir/etc/users.properties ファイルまたは karaf jaas コマンドによって設定されたパスワードです。

Finish をクリックします。

Runtime Server [stopped, Synchronized] が Servers ビューに表示されます。

Servers ビューで Runtime Server を展開します。

jmx[Disconnected] が、Runtime Server [stopped, synced] エントリーの下にノードとして表示されます。

サーバーの Overview ページで Publishing セクションを展開し、オプションを表示します。

オプション Automatically publish when resources change を必ず有効にしてください。

必要に応じて、Publishing interval の値を変更して、変更されたプロジェクトのパブリッシュをスピードアップまたは遅延させます。

サーバーが起動するまで数秒待機します。起動すると以下のようになります。

Servers ビューで n.n Runtime Server [Started] を右クリックし、Add and Remove を選択して Add and Remove ページを開きます。

オプション If server is started, publish changes immediately のチェックを選択するようにしてください。

ZooOrderApp を選択し、Add をクリックして Fuse サーバーに割り当てます。

Finish をクリックします。

Servers ビューには以下が表示されるはずです。

JMX Navigator で Camel フォルダーを展開し、ZooOrderApp の要素を表示します。

Bundles ノードをクリックし、Properties ビューに、ランタイムサーバーにインストールされているバンドルのリストを反映させます。

Search フィールドで ZooOrderApp を入力します。対応するバンドルが表示されます。

注記

または、Terminal ビューで osgi:list コマンドを実行し、サーバーランタイムにインストールされているバンドルに関する生成されたリストを表示することもできます。ツールは、osgi:list コマンドが表示する OSGi バンドルに異なる命名スキームを使用します。この場合、コマンドは Camel Blueprint Quickstart を返します。これはインストールされたバンドルのリストの最後に表示される

プロジェクトの pom.xml ファイルの <build> セクションで、バンドルのシンボリック名およびそのバンドル名 (OSGi) が maven-bundle-plugin エントリーに一覧表示されます。

Add and Remove を選択します。

Servers ビューで JMX[Connected] を右クリックし、Refresh をクリックします。

JMX[Connected] 下の Camel ツリーが消えます。