第133章 Hazelcast Topic コンポーネント
Camel バージョン 2.15 から利用可能
Hazelcast Topic コンポーネントは Camel Hazelcast コンポーネントの 1 つで、Hazelcast 分散トピックにアクセスできます。
133.1. オプション
Hazelcast Topic コンポーネントは、以下に示す 3 つのオプションをサポートします。
Name | 説明 | デフォルト | Type |
---|---|---|---|
hazelcastInstance (advanced) | hazelcast エンドポイントに使用できる hazelcast インスタンス参照。インスタンスの参照を指定しない場合、Camel は camel-hazelcast インスタンスのデフォルトの hazelcast インスタンスを使用します。 | HazelcastInstance | |
hazelcastMode (advanced) | 使用すべきインスタンスの種類を示す hazelcast モード参照。モードを指定しない場合、ノードモードがデフォルトになります。 | node | 文字列 |
resolveProperty Placeholders (advanced) | 起動時にコンポーネント自体がプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。 | true | boolean |
Hazelcast Topic エンドポイントは、URI 構文を使用して設定します。
hazelcast-topic:cacheName
以下の path パラメーターおよびクエリーパラメーターを使用します。
133.1.1. パスパラメーター(1 パラメーター):
Name | 説明 | デフォルト | Type |
---|---|---|---|
cacheName | 必要な キャッシュの名前 | 文字列 |
133.1.2. クエリーパラメーター(16 パラメーター):
Name | 説明 | デフォルト | Type |
---|---|---|---|
defaultOperation (common) | 使用するデフォルトの操作を指定します(操作ヘッダーが指定されていない場合)。 | HazelcastOperation | |
hazelcastInstance (common) | hazelcast エンドポイントに使用できる hazelcast インスタンス参照。 | HazelcastInstance | |
hazelcastInstanceName (common) | hazelcast エンドポイントに使用できる hazelcast インスタンス参照名。インスタンスの参照を指定しない場合、Camel は camel-hazelcast インスタンスのデフォルトの hazelcast インスタンスを使用します。 | 文字列 | |
reliable (common) | エンドポイントが信頼できる Topic 構造を使用するかどうかを定義します。 | false | boolean |
bridgeErrorHandler (consumer) | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | boolean |
pollingTimeout (consumer) | キューコンシューマーのポーリングタイムアウトをポーリングモードで定義 | 10000 | Long |
poolSize (consumer) | キューコンシューマーエグゼキューターのプールサイズの定義 | 1 | int |
queueConsumerMode (consumer) | キューコンシューマーモードの定義: Listen または Poll | listen | HazelcastQueueConsumer Mode |
exceptionHandler (consumer) | コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されていないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | ExceptionHandler | |
exchangePattern (consumer) | コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。 | ExchangePattern | |
同期 (詳細) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します(サポートされている場合)。 | false | boolean |
concurrentConsumers (seda) | SEDA キューからポーリングされる同時コンシューマーを使用するには、以下を行います。 | 1 | int |
onErrorDelay (seda) | エラー発生後にコンシューマーがポーリングを継続する前にミリ秒単位です。 | 1000 | int |
pollTimeout (seda) | SEDA キューから消費する際に使用するタイムアウト。タイムアウトが発生すると、コンシューマーは実行を継続できるかどうかを確認できます。値を低く設定すると、シャットダウン時にコンシューマーがより迅速に反応できるようになります。 | 1000 | int |
トランザクション処理 (seda) | true に設定すると、コンシューマーはトランザクションモードで実行され、seda キューのメッセージはトランザクションがコミットされた場合にのみ削除されます。これは処理の完了時に行われます。 | false | boolean |
transferExchange (seda) | true に設定すると、Exchange 全体が転送されます。ヘッダーまたはボディーにシリアライズ可能なオブジェクトが含まれていない場合、それらは省略されます。 | false | boolean |