手順
-
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の作成と使用については、 Talend Studioユーザーガイドを参照してください。 -
MonitorというcProcessorコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
-
[Code] (コード)エリアでコードをカスタマイズして、消費されたメッセージのファイル名を[Run] (実行)コンソールに表示します。
System.out.println("Message consumed: "+ exchange.getIn().getHeader("CamelFileName"));
- [Ctrl] + [S]を押してジョブを保存します。