検索

273.2. オプション

download PDF

Reactive Streams コンポーネントは、以下に示す 4 個のオプションをサポートしています。

名前説明デフォルトタイプ

internalEngine Configuration (advanced)

Reactive Streams の内部エンジンを設定します。

 

ReactiveStreamsEngine 設定

backpressureStrategy (producer)

イベントを遅いスサブスクライバーにプッシュするときに使用するバックプレッシャーストラテジー。

BUFFER

ReactiveStreams BackpressureStrategy

serviceType (advanced)

使用する基礎となるリアクティブストリームの実装のタイプを設定します。実装はレジストリーから、または ServiceLoader を使用して検索されます。デフォルトの実装は DefaultCamelReactiveStreamsService です。

 

String

resolveProperty Placeholders (advanced)

起動時にコンポーネントがプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。

true

boolean

Reactive Streams エンドポイントは、URI 構文を使用して設定されます。

reactive-streams:stream

パスおよびクエリーパラメーターを使用します。

273.2.1. パスパラメーター (1 個のパラメーター):

名前説明デフォルトタイプ

stream

エンドポイントがメッセージをエクスチェンジするために使用するストリームチャネルの名前。

 

String

273.2.2. クエリーパラメーター (10 パラメーター)

名前説明デフォルトタイプ

bridgeErrorHandler (consumer)

consumer の Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、consumer が受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、consumer は org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

boolean

concurrentConsumers (consumer)

Camel ルートでエクスチェンジを処理するために使用されるスレッドの数。

1

int

exchangesRefillLowWatermark (consumer)

maxInflightExchanges のパーセンテージとして、リクエストされたエクスチェンジの下限をアクティブなサブスクリプションに設定します。アップストリームソースからの保留中のアイテムの数がウォーターマークより少ない場合、新しいアイテムをサブスクリプションにリクエストできます。0 に設定すると、サブスクライバーは、前のバッチのすべてのアイテムが処理された後でのみ、maxInflightExchanges のバッチでアイテムをリクエストします。1 に設定すると、サブスクライバーは、エクスチェンジが処理されるたびに新しいアイテムをリクエストできます (chatty)。任意の中間値を使用できます。

0.25

double

forwardOnComplete (consumer)

onComplete イベントを Camel ルートにプッシュするかどうかを決定します。

false

boolean

forwardOnError (consumer)

onError イベントを Camel ルートにプッシュするかどうかを決定します。例外はメッセージボディーとして設定されます。

false

boolean

maxInflightExchanges (consumer)

Camel によって同時に処理されるエクスチェンジの最大数。このパラメーターは、ストリームのバックプレッシャーを制御します。正でない値を設定すると、バックプレッシャーが無効になります。

128

Integer

exceptionHandler (consumer)

コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、consumer は例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

 

ExceptionHandler

exchangePattern (consumer)

コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。

 

ExchangePattern

backpressureStrategy (producer)

イベントを遅いスサブスクライバーにプッシュするときに使用するバックプレッシャーストラテジー。

 

ReactiveStreams BackpressureStrategy

synchronous (advanced)

同期処理を厳密に使用するか、Camel が非同期処理を使用できるかどうかを設定します (サポートされている場合)。

false

boolean

Red Hat logoGithubRedditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

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

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

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

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

会社概要

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

© 2024 Red Hat, Inc.