Tooling Tutorials

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 version を受け入れます。

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

Finish をクリックします。

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

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

Yes をクリックします。

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

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

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

エディター設定ページを開きます。

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 タブをクリックします。

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

たとえば、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>

File コンポーネント ( ) を Palette の Components ドロワーからキャンバスにドラッグし、それを 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 ページを開きます。

ツールは、Advanced 設定タブで設定した Directory Name と Noop プロパティーを Uri フィールドに自動的に入力することに注意してください。また、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 ノードに子ノードが必要なことを示しています。子ノードは、次のステップで追加します。

Routing ドロワーから、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 と入力します。

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

完成したコンテンツベースのルーターは次のようになります。

キャンバスの左下にある 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 ノードに無条件ブレークポイントを設定します。

Message1 が最初のブレークポイント _choice1 in _route1 [blueprint.xml] で停止した場合、変数 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 フォルダーにコンテキストを一覧表示します。

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

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

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

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

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

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

すべてのメッセージフローパスを明確に表示するには、ノードをドラッグして Diagram View タブにぴったり収まるようにノードを再配置する必要があります。また、Red Hat CodeReady Studio の他のビューとタブのサイズを調整して、Diagram View タブを拡張できるようにする必要がある場合もあります。

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

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 ノードにドラッグし、ドロップすることができます。

ドロップするたびに、 (更新ボタン) をクリックし、Messages View に新しいメッセージのトレースを入力することを忘れないでください。

それが終わったら:

このチュートリアルを開始するには、次のいずれかの結果である 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/test/java フォルダーが src/main/resources フォルダーの下に表示されます。

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

右クリックして、New → Camel Test Case を選択します。

Camel XML file under test フィールドで、 をクリックし、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;

protected Object[] expectedBodies={ …​…​ expectedBody2</something>"}; の行を 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「トレースで生成されたメッセージ」を参照)。

以下をクリックします。利用可能なサーバーはありません。このリンクをクリックして、新しいサーバーを作成...リンクをクリックすると、Define a New Server ページが表示されます。

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

Server's host name ( localhost) と Server name (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 ビューで、ランタイムサーバーを展開します。

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

サーバーの 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 ツリーが消えます。