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

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

[+]ボタンをクリックして[Exceptions] (例外) テーブルに行を追加し、キャッチする例外を定義します。この例では、java.io.IOExceptionと入力してIO例外を処理します。

[Exception behavior] (例外の動作)エリアで[Ignore the exceptions] (例外の無視)オプションを選択して例外を無視し、メッセージのルーティングを続行します。その他のパラメーターはそのままにしておきます。

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

[Path] (パス)フィールドにメッセージソースのパスを入力し、その他のパラメーターはそのままにしておきます。

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

[New Instance] (新しいインスタンス)を選択し、[Bean class] (Beanクラス)フィールドに、IO例外を返すBeanの名前(このシナリオではbeans.throwIOException.class)を入力します。

このBeanは既に[Repository] (リポジトリー)の[Code] (コード)ノードで定義されており、次のようになっています。

package beans;

import java.io.IOException;

import org.apache.camel.Exchange;


public class throwIOException {

    /**

     * @throws IOException 
     */
    public static void helloExample(String message, Exchange exchange) throws IOException {
        throw new IOException("An IOException has been caught");
    }
}

JavaBeansの作成と使用については、Beansを使用をご覧ください。

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

[Code] (コード)エリアでコードをカスタマイズして、消費されたメッセージのファイル名を[Run] (実行)コンソールに表示します。

System.out.println("Message consumed: "+ 
exchange.getIn().getHeader("CamelFileName"));

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

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

Logs and errors (メディエーション)

手順