284.2.2. クエリーパラメーター(23 パラメーター):


Expand
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 がルートで出力されます。

トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat