第149章 ignite Events コンポーネント
Camel バージョン 2.17 から利用可能
Ignite Events エンドポイントは camel-ignite エンドポイントの 1 つで、ローカル イベントリスナーを作成して、Ignite クラスターからイベントを受信 できます。
このエンドポイントはコンシューマーのみをサポートします。このコンシューマーによって作成されたエクスチェンジは、受信したイベントオブジェクトを IN メッセージのボディーに配置します。
149.1. オプション
Ignite Events コンポーネントは、以下に示す 4 つのオプションをサポートします。
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| ignite (consumer) | Ignite インスタンスを設定します。 | ignite | |
| configurationResource (consumer) | 設定の読み込み元となるリソースを設定します。URI、String(URI)、または InputStream を指定できます。 | オブジェクト | |
| igniteConfiguration (consumer) | ユーザーがプログラムによる IgniteConfiguration を設定できるようにします。 | IgniteConfiguration | |
| resolveProperty Placeholders (advanced) | 起動時にコンポーネント自体がプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。 | true | boolean |
Ignite Events エンドポイントは、URI 構文を使用して設定します。
ignite-events:endpointId
以下の path パラメーターおよびクエリーパラメーターを使用します。
149.1.1. パスパラメーター（1 パラメーター）:
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| endpointId | エンドポイント ID（不使用）。 | 文字列 |
149.1.2. クエリーパラメーター（8 パラメーター）:
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| bridgeErrorHandler (consumer) | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | boolean |
| clusterGroupExpression (consumer) | クラスターグループ式。 | ClusterGroupExpression | |
| イベント （コンシューマー） | ID が org.apache.ignite.events.EventType の異なる定数である Set として直接サブスクライブするイベント ID。 | EventType.EVTS_ALL | Set<Integer>OrString |
| propagateIncomingBodyIfNo ReturnValue (consumer) | 基礎となる Ignite 操作の戻り値タイプが void の場合には、受信ボディーを伝播するかどうかを設定します。 | true | boolean |
| treatCollectionsAsCache Objects (consumer) | コレクションをキャッシュオブジェクトとして処理するか、または挿入/更新/コンピュートなどを行う項目のコレクションとして処理するかどうかを設定します。 | false | boolean |
| exceptionHandler (consumer) | コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されていないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | ExceptionHandler | |
| exchangePattern (consumer) | コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。 | ExchangePattern | |
| 同期 （詳細） | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します（サポートされている場合）。 | false | boolean |
