第152章 ignite Queues Component
Camel バージョン 2.17 から利用可能
Ignite Queue エンドポイントは camel-ignite エンドポイントの 1 つで、Ignite Queue データ構造と対話できます。
このエンドポイントはプロデューサーのみをサポートします。
152.1. オプション
Ignite Queues コンポーネントは、以下に示す 4 つのオプションをサポートします。
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| ignite (producer) | Ignite インスタンスを設定します。 | ignite | |
| configurationResource (producer) | 設定の読み込み元となるリソースを設定します。URI、String(URI)、または InputStream を指定できます。 | オブジェクト | |
| igniteConfiguration (producer) | ユーザーがプログラムによる IgniteConfiguration を設定できるようにします。 | IgniteConfiguration | |
| resolveProperty Placeholders (advanced) | 起動時にコンポーネント自体がプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。 | true | boolean |
Ignite Queues エンドポイントは、URI 構文を使用して設定します。
ignite-queue:name
以下の path パラメーターおよびクエリーパラメーターを使用します。
152.1.1. パスパラメーター（1 パラメーター）:
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| name | 必須。キュー名。 | 文字列 |
152.1.2. クエリーパラメーター（7 パラメーター）:
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| 容量 （プロデューサー） | キューの容量。デフォルト： バインドなし。 | int | |
| 設定 （プロデューサー） | コレクションの設定。デフォルト： 空の設定。また、configuration.xyz=123 オプションを使用して内部プロパティーを設定することもできます。 | CollectionConfiguration | |
| 操作 （プロデューサー） | Ignite Queue で呼び出す操作。IN メッセージの IgniteConstants.IGNITE_QUEUE_OPERATION ヘッダーに置き換えられました。使用できる値は、CONTAINS、ADD、SIZE、REMOVE、ITERATOR、CLEAR、RETAIN_ALL、ARRAY、DRAIN、ELEMENT、PEEK、OFFER、POLL、TAKE、PUT です。 | IgniteQueueOperation | |
| propagateIncomingBodyIfNo ReturnValue (producer) | 基礎となる Ignite 操作の戻り値タイプが void の場合には、受信ボディーを伝播するかどうかを設定します。 | true | boolean |
| timeoutMillis (producer) | キューのタイムアウト（ミリ秒単位）。デフォルト： タイムアウトなし。 | Long | |
| treatCollectionsAsCache Objects (producer) | コレクションをキャッシュオブジェクトとして処理するか、または挿入/更新/コンピュートなどを行う項目のコレクションとして処理するかどうかを設定します。 | false | boolean |
| 同期 （詳細） | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します（サポートされている場合）。 | false | boolean |
152.1.3. 使用されるヘッダー
このエンドポイントは、以下のヘッダーを使用します。
| ヘッダー名 | Constant | 想定されるタイプ | 説明 |
|---|---|---|---|
| CamelIgniteQueueOperation | IgniteConstants.IGNITE_QUEUE_OPERATION | IgniteQueueOperation enum | キュー操作を動的に変更できます。 |
| CamelIgniteQueueMaxElements | IgniteConstants.IGNITE_QUEUE_MAX_ELEMENTS | 整数または int | DRAIN 操作を呼び出す場合、ドレイン（解放）する項目の量。 |
| CamelIgniteQueueTransferredCount | IgniteConstants.IGNITE_QUEUE_TRANSFERRED_COUNT | 整数または int | DRAIN 操作の結果として転送される項目の量。 |
| CamelIgniteQueueTimeoutMillis | IgniteConstants.IGNITE_QUEUE_TIMEOUT_MILLIS | long または long | OFFER または POLL 操作の呼び出し時に使用するタイムアウトをミリ秒単位で設定します。 |
