284.2.2. クエリーパラメーター(23 パラメーター):
| Name | 説明 | デフォルト | Type |
|---|---|---|---|
| aggregationStrategy (consumer) | バッチされたすべてのメッセージを 1 つのメッセージにマージする、使用する集約ストラテジーが 必要です。 | AggregationStrategy | |
| allowNullBody (consumer) | ボディーのないメッセージの送信を許可するかどうか。このオプションが false で、メッセージボディーが null の場合、JMSException が発生します。 | true | boolean |
| bridgeErrorHandler (consumer) | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | boolean |
| completionInterval (consumer) | ミリ秒単位の完了間隔。これにより、スケジュールされたレートでバッチが間隔ごとに完了します。タイムアウトが発生し、バッチにメッセージがない場合にバッチは空になることがあります。完了のタイムアウトと完了間隔を同時に使用することができないことに注意してください。設定できるのは 1 つのみです。 | 1000 | int |
| completionPredicate (consumer) | 完了述語。これにより、述語が true と評価されるとバッチが完了します。述語は、文字列構文を使用して Simple 言語を使用して設定することもできます。オプション eagerCheckCompletion を true に設定して、述語が受信メッセージと一致するようにします。そうでない場合は集約されたメッセージと一致します。 | 文字列 | |
| completionSize (consumer) | バッチの完了時に消費されるメッセージの数 | 200 | int |
| completionTimeout (consumer) | バッチの完了時に最初のメッセージの最初のメッセージから受信までのタイムアウト(ミリ秒単位)。タイムアウトが発生し、バッチにメッセージがない場合にバッチは空になることがあります。完了のタイムアウトと完了間隔を同時に使用することができないことに注意してください。設定できるのは 1 つのみです。 | 500 | int |
| consumerCount (consumer) | 消費する JMS セッションの数 | 1 | int |
| eagerCheckCompletion (consumer) | Eager completion チェックを使用します。これは、completionPredicate が受信エクスチェンジを使用することを意味します。completionPredicate を確認せずに、集約されたエクスチェンジを使用します。 | false | boolean |
| includeAllJMSXProperties (consumer) | JMS から Camel メッセージへのマッピング時に、すべての JMSXxxx プロパティーを含めるかどうか。これを true に設定すると、JMSXAppID や JMSXUserID などのプロパティーが含まれます。注記: カスタムの headerFilterStrategy を使用している場合は、このオプションは適用されません。 | false | boolean |
| mapJmsMessage (consumer) | Camel が受信した JMS メッセージを適切なペイロードタイプ(javax.jms.TextMessage など)に自動マッピングするかどうかを指定します。詳細は、以下のマッピングがどのように機能するかについてのセクションを参照してください。 | true | boolean |
| pollDuration (コンシューマー) | メッセージのポーリングごとにミリ秒単位の時間。completionTimeOut は短く、バッチが開始されている場合に使用されます。 | 1000 | int |
| sendEmptyMessageWhenIdle (consumer) | 完了のタイムアウトまたは間隔を使用する場合、タイムアウトが発生し、バッチにメッセージがない場合にバッチを空になることがあります。このオプションが true でバッチが空の場合、空のメッセージがバッチに追加され、空のメッセージがルーティングされます。 | false | boolean |
| exceptionHandler (consumer) | コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されていないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | ExceptionHandler | |
| exchangePattern (consumer) | コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。 | ExchangePattern | |
| asyncStartListener (advanced) | ルートの開始時にコンシューマーメッセージリスナーを非同期に起動するかどうか。たとえば、JmsConsumer がリモート JMS ブローカーへの接続を取得できない場合は、再試行中やフェイルオーバー中にブロックされる可能性があります。これにより、ルートの起動中に Camel がブロックされます。このオプションを true に設定すると、ルートの起動が可能になりますが、JmsConsumer は非同期モードで専用のスレッドを使用して JMS ブローカーに接続します。このオプションを使用すると、接続が確立されないと、WARN レベルで例外がログに記録され、コンシューマーはメッセージを受信できなくなります。次にルートを再起動して再試行できます。 | false | boolean |
| headerFilterStrategy (advanced) | カスタム HeaderFilterStrategy を使用して Camel メッセージに対してヘッダーをフィルターします。 | HeaderFilterStrategy | |
| jmsKeyFormatStrategy (advanced) | JMS 鍵をエンコードおよびデコードするためのプラグ可能なストラテジー。これにより、JMS 仕様に準拠します。Camel は、追加設定なしで、default と passthrough の 2 つの実装を提供します。デフォルトのストラテジーは、ドットとハイフン(. および -)を安全にマーシャリングします。passthrough ストラテジーは、鍵をそのまま残します。JMS ヘッダーキーに不正な文字が含まれるかどうかは気にしない JMS ブローカーに使用できます。org.apache.camel.component.jms.JmsKeyFormatStrategy の独自の実装を提供し、表記を使用して参照できます。 | JmsKeyFormatStrategy | |
| keepAliveDelay (advanced) | 有効なセッションを再確立するまでの遅延(ミリ秒単位)。これが正の値である場合、SjmsBatchConsumer はメッセージの消費中に IllegalStateException が表示されると、新しいセッションを作成しようとします。この遅延値により、ログのスパムを防ぐことができます。これが負の値である場合(デフォルトは -1)、SjmsBatchConsumer は、常に処理する前に動作します。つまり、IllegalStateException が表示される場合、ルートはシャットダウンします。 | -1 | int |
| messageCreatedStrategy (advanced) | Camel が JMS メッセージを送信するときに Camel が javax.jms.Message オブジェクトの新規インスタンスを作成する際に呼び出される指定の MessageCreatedStrategy を使用します。 | MessageCreatedStrategy | |
| recoveryInterval (advanced) | リカバリーを試行する間隔を指定します(例: 接続の更新時(ミリ秒単位)。デフォルトは 5000 ミリ秒で、5 秒です。 | 5000 | int |
| 同期 (詳細) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します(サポートされている場合)。 | false | boolean |
| timeoutCheckerExecutor Service (advanced) | completionInterval オプションを使用している場合は、バックグラウンドスレッドが作成され、完了間隔がトリガーされます。すべてのコンシューマーに新しいスレッドを作成するのではなく、カスタムスレッドプールを提供する場合に使用します。 | ScheduledExecutor Service |
completionSize エンドポイント属性は completionTimeout と併用されます。最初の条件が満たされると、集約された Exchange がルートで出力されます。