第159章 Ignite Queues コンポーネント
Camel バージョン 2.17 以降で利用可能
Ignite Queue エンドポイントは camel-ignite エンドポイントの 1 つで、Ignite Queue のデータ構造 を操作できるようにします。
このエンドポイントはプロデューサーのみをサポートします。
159.1. オプション
Ignite Queues コンポーネントは、以下に示す 4 個のオプションをサポートしています。
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| ignite (producer) | Ignite インスタンスを設定します。 | Ignite | |
| configurationResource (producer) | 設定をロードするリソースを設定します。URI、文字列 (URI)、または InputStream のいずれかです。 | Object | |
| igniteConfiguration (producer) | ユーザーがプログラムによる IgniteConfiguration を設定できるようにします。 | IgniteConfiguration | |
| resolveProperty Placeholders (advanced) | 起動時にコンポーネントがプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。 | true | boolean |
Ignite Queues エンドポイントは、URI 構文を使用して設定されます。
ignite-queue:name
パスおよびクエリーパラメーターを使用します。
159.1.1. パスパラメーター (1 個のパラメーター):
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| name | 必須 キュー名。 | String |
159.1.2. クエリーパラメーター (7 個のパラメーター):
| 名前 | 説明 | デフォルト | タイプ |
|---|---|---|---|
| capacity (producer) | キュー容量。デフォルト: 無制限。 | int | |
| configuration (producer) | コレクション設定。デフォルト: 空の設定。configuration.xyz=123 オプションを使用して内部プロパティーを簡単に設定することもできます。 | CollectionConfiguration | |
| operation (producer) | 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 |
| synchronous (advanced) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。 | false | boolean |
159.1.3. 使用されるヘッダー
このエンドポイントは、次のヘッダーを使用します。
| ヘッダー名 | 定数 | 想定されるタイプ | 説明 |
|---|---|---|---|
| CamelIgniteQueueOperation | IgniteConstants.IGNITE_QUEUE_OPERATION | IgniteQueueOperation enum | キュー操作を動的に変更できます。 |
| CamelIgniteQueueMaxElements | IgniteConstants.IGNITE_QUEUE_MAX_ELEMENTS | Integer または int | DRAIN 操作を呼び出すときの、解放する項目の量。 |
| CamelIgniteQueueTransferredCount | IgniteConstants.IGNITE_QUEUE_TRANSFERRED_COUNT | Integer または int | DRAIN 操作の結果として転送されたアイテムの量。 |
| CamelIgniteQueueTimeoutMillis | IgniteConstants.IGNITE_QUEUE_TIMEOUT_MILLIS | Long または long | OFFER または POLL 操作を呼び出すときに使用するタイムアウトをミリ秒単位で動的に設定します。 |
