46.4. プログラミングモデル
概要
API コンポーネントフレームワークのコンテキストでは、主なコンポーネント実装クラスは org.apache.camel.util.component
パッケージのベースクラスから派生します。これらのベースクラスは、コンポーネントの実装時に (任意で) オーバーライドできるメソッドを定義します。このセクションでは、これらのメソッドと、コンポーネントの実装でこれらを使用する方法についての概要を説明します。
実装するコンポーネントメソッド
生成されるメソッド実装 (通常は変更する必要はありません) のほかに、Component
クラスの以下のメソッドの一部を任意で上書きすることもできます。
doStart()
-
(任意) コールド起動時にコンポーネントのリソースを作成するためのコールバック。別の方法としては、遅延初期化 の設定 (リソースが必要な場合のみ作成) を実行する方法があります。実際、遅延初期化が最適なストラテジーとなることが多いため、
doStart
メソッドは必要ないことがよくあります。 doStop()
(任意) コンポーネントが停止している間にコードを呼び出すコールバック。コンポーネントを停止すると、そのリソースがすべてシャットダウンされ、内部状態が削除され、キャッシュが消去されることを意味します。
注記Camel は、対応する
doStart
が呼び出されなかった場合でも、現在のCamelContext
のシャットダウン時に 常にdoStop
が呼び出されることを保証します。doShutdown
-
(オプション)
CamelContext
がシャットダウンしている間にコードを呼び出すコールバック。停止したコンポーネントを再起動することはできますが (コールドスタートのセマンティクスを使用)、シャットダウンするコンポーネントが完全に終了します。したがって、このコールバックは、コンポーネントに属するリソースを解放する最後の可能性を表します。
その他に Component クラスに実装するもの
Component
クラスは、コンポーネントオブジェクト自体に同じ(または同様の)ライフサイクルを持つオブジェクトへの参照を保持するための自然な場所です。たとえば、コンポーネントが OAuth セキュリティーを使用する場合、Component
クラスで必要な OAuth オブジェクトへの参照を保持し、OAuth オブジェクトを作成するための Component
クラスでメソッドを定義することが自然になります。
実装するエンドポイントメソッド
生成されたメソッドの一部を変更し、必要に応じて、以下のように Endpoint
クラスの継承されたメソッドの一部を上書きすることができます。
afterConfigureProperties()
この方法で必要なのは、API 名に一致するプロキシークラス (API クラス) を作成することです。API 名(エンドポイント URI から抽出されている)は、継承された
apiName
フィールドまたはgetApiName
アクセサーを介して利用できます。通常、apiName
フィールドでスイッチを実行して、対応するプロキシークラスを作成します。以下に例を示します。// Java private Object apiProxy; ... @Override protected void afterConfigureProperties() { // TODO create API proxy, set connection properties, etc. switch (apiName) { case HELLO_FILE: apiProxy = new ExampleFileHello(); break; case HELLO_JAVADOC: apiProxy = new ExampleJavadocHello(); break; default: throw new IllegalArgumentException("Invalid API name " + apiName); } }
getApiProxy(ApiMethod method, Map<String, Object> args)
このメソッドを上書きして、
afterConfigureProperties
で作成したプロキシーインスタンスを返します。以下に例を示します。@Override public Object getApiProxy(ApiMethod method, Map<String, Object> args) { return apiProxy; }
特殊なケースでは、API メソッドおよび引数に依存するプロキシーを選択する必要がある場合があります。必要に応じて、
getApiProxy
で、このアプローチを柔軟に行うことができます。doStart()
-
(任意) コールド起動時にリソースを作成するためのコールバック。
Component.doStart()
と同じセマンティクスがあります。 doStop()
-
(任意) コンポーネントが停止している間にコードを呼び出すコールバック。
Component.doStop()
と同じセマンティクスがあります。 doShutdown
-
(オプション) コンポーネントがシャットダウンしている間にコードを呼び出すコールバック。
Component.doShutdown()
と同じセマンティクスがあります。 interceptPropertyNames(Set<String> propertyNames)
(任意) API コンポーネントフレームワークは、エンドポイント URI と指定されたオプション値を使用して、呼び出す方法を決定します (オーバーロードおよびエイリアスによる曖昧さ)。ただし、コンポーネントが内部的にオプションまたはメソッドパラメーターを追加する場合、このフレームワークでは呼び出す適切な方法を判断するためにヘルプが必要になる場合があります。この場合、
interceptPropertyNames
メソッドを上書きし、プロパティーNames
セットに追加(非表示または暗黙的)オプションを追加する必要があります。メソッドパラメーターの完全なリストがpropertyNames
セットに提供されると、フレームワークは呼び出す適切なメソッドを特定できます。注記このメソッドは
Endpoint
、Producer
、またはConsumer
クラスのレベルで上書きできます。基本的なルールは、オプションがプロデューサーエンドポイントとコンシューマーエンドポイントの 両方 に影響する場合に、Endpoint
クラスのメソッドを上書きします。interceptProperties(Map<String,Object> properties)
(任意) このメソッドを上書きすると、API メソッドが呼び出される前に、オプションの実際の値を変更または設定できます。たとえば、この方法を使用して、必要に応じて、一部のオプションにデフォルト値を設定できます。実際には、
interceptPropertyNames
メソッドおよびinterceptProperty
メソッドの両方を上書きする必要があることが多いです。注記このメソッドは
Endpoint
、Producer
、またはConsumer
クラスのレベルで上書きできます。基本的なルールは、オプションがプロデューサーエンドポイントとコンシューマーエンドポイントの 両方 に影響する場合に、Endpoint
クラスのメソッドを上書きします。
実装するコンシューマーメソッド
任意で、以下のように Consumer
クラスで継承されたメソッドの一部を上書きできます。
interceptPropertyNames(Set<String> propertyNames)
-
(任意) このメソッドのセマンティクスは、
Endpoint.interceptPropertyNames
と似ています。 interceptProperties(Map<String,Object> properties)
-
(任意) このメソッドのセマンティクスは、
Endpoint.interceptProperties
と似ています。 doInvokeMethod(Map<String, Object> args)
(任意) このメソッドを上書きすると、Java API メソッドの呼び出しを妨害できます。このメソッドを上書きする最も一般的な理由は、メソッド呼び出しに関するエラー処理をカスタマイズすることです。たとえば、以下のコードフラグメントに
doInvokeMethod
を上書きする一般的な方法が示されています。// Java @Override protected Object doInvokeMethod(Map<String, Object> args) { try { return super.doInvokeMethod(args); } catch (RuntimeCamelException e) { // TODO - Insert custom error handling here! ... } }
この実装の時点で、Java API メソッドが呼び出されるように、スーパークラスで
doInvokeMethod
を呼び出す必要があります。interceptResult(Object methodResult, Exchange resultExchange)
-
(任意) API メソッド呼び出しの結果に追加処理を行います。たとえば、この時点でカスタムヘッダーを Camel エクスチェンジオブジェクト
resultExchange
に追加できます。 Object splitResult(Object result)
(任意) デフォルトでは、メソッド API 呼び出しの結果が
java.util.Collection
オブジェクトまたは Java アレイである場合、API コンポーネントフレームワークは結果を 複数 のエクスチェンジオブジェクトに分割します(これにより、単一の呼び出しの結果が複数のメッセージに変換されます)。デフォルトの動作を変更する場合は、コンシューマーエンドポイントで
splitResult
メソッドを上書きすることができます。result
引数には、API メッセージ呼び出しの結果が含まれます。結果を分割する場合は、配列タイプを返す必要があります。注記エンドポイント URI で
consumer.splitResult=false
に設定して、デフォルトの分割動作をオフにすることもできます。
実装するプロデューサーメソッド
任意で、以下のように継承されたメソッドの一部を Producer
クラスで上書きできます。
interceptPropertyNames(Set<String> propertyNames)
-
(任意) このメソッドのセマンティクスは、
Endpoint.interceptPropertyNames
と似ています。 interceptProperties(Map<String,Object> properties)
-
(任意) このメソッドのセマンティクスは、
Endpoint.interceptProperties
と似ています。 doInvokeMethod(Map<String, Object> args)
-
(任意) このメソッドのセマンティクスは、
Consumer.doInvokeMethod
と似ています。 interceptResult(Object methodResult, Exchange resultExchange)
-
(任意) このメソッドのセマンティクスは、
Consumer.interceptResult
と似ています。
Producer.splitResult()
メソッドは呼び出しされないため、API メソッドの結果を、コンシューマーエンドポイントの場合と同じ方法で分割することはできません。プロデューサーエンドポイントに同様の効果を取得するには、Camel の split(
)DSL コマンド(標準のエンタープライズ統合パターンの 1 つ)を使用して Collection
または配列の結果を分割できます。
コンシューマーポーリングおよびスレッドモデル
API コンポーネントフレームワークのコンシューマーエンドポイントのデフォルトのスレッドモデルは、スケジュールされたポーリングコンシューマーです。これは、コンシューマーエンドポイントの API メソッドが、定期的なスケジュールされた時間間隔で呼び出されることを意味します。詳細は、「スケジュールされたポーリングコンシューマーの実装」 を参照してください。