検索

272.2. オプション

download PDF

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

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

hostname (common)

実行中の RabbitMQ インスタンスまたはクラスターのホスト名。

 

String

portNumber (Common)

実行中の rabbitmq インスタンスまたはクラスターを持つホストのポート番号。

5672

int

username (security)

認証アクセスの場合のユーザー名

guest

String

password (security)

認証アクセス用のパスワード

guest

String

vhost (Common)

チャネルの仮想ホスト

/

String

addresses (Common)

このオプションが設定されている場合、camel-rabbitmq はオプションアドレスの設定に基づいて接続を作成しようとします。アドレスの値は、server1:12345、server2:12345 のような文字列です。

 

String

connectionFactory (common)

カスタム RabbitMQ 接続ファクトリーを使用するには。このオプションが設定されている場合、URI に設定されているすべての接続オプション (connectionTimeout、requestedChannelMax など) は使用されません。

 

ConnectionFactory

threadPoolSize (consumer)

コンシューマーは、固定数のスレッドで Thread Pool Executor を使用します。この設定により、そのスレッド数を設定できます。

10

int

autoDetectConnection Factory (advanced)

レジストリーからの RabbitMQ 接続ファクトリーの検索を自動検出するかどうか。有効にすると、接続ファクトリーのインスタンスが 1 つだけ検出され、それが使用されます。明示的な接続ファクトリーは、優先されるコンポーネントまたはエンドポイントレベルで設定できます。

true

boolean

connectionTimeout (advanced)

Connection timeout

60000

int

requestedChannelMax (advanced)

接続要求されたチャネルの最大数 (提供されるチャネルの最大数)

2047

int

requestedFrameMax (advanced)

接続要求フレーム最大 (提供されるフレームの最大サイズ)

0

int

requestedHeartbeat (advanced)

接続要求されたハートビート (提供される秒単位のハートビート)

60

int

automaticRecovery Enabled (advanced)

接続の自動回復を有効にします (接続のシャットダウンがアプリケーションによって開始されない場合に自動回復を実行する接続の実装を使用します)

 

Boolean

networkRecoveryInterval (advanced)

ミリ秒単位のネットワーク回復間隔 (ネットワーク障害からの回復時に使用される間隔)

5000

Integer

topologyRecoveryEnabled (advanced)

接続トポロジーの回復を有効にします (トポロジーの回復を実行する必要があります)。

 

Boolean

prefetchEnabled (consumer)

RabbitMQConsumer 側でサービス品質を有効にします。prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります。

false

boolean

prefetchSize (consumer)

サーバーが配信するコンテンツの最大量 (オクテットで測定)。無制限の場合は 0。prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります。

 

int

prefetchCount (consumer)

サーバーが配信するメッセージの最大数。無制限の場合は 0。prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります。

 

int

prefetchGlobal (consumer)

各コンシューマーではなく、チャネル全体に設定を適用する場合 prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります

false

boolean

channelPoolMaxSize (producer)

プールで開かれているチャネルの最大数を取得する

10

int

channelPoolMaxWait (producer)

プールからのチャネルを待機する最大ミリ秒数を設定します

1000

long

requestTimeout (advanced)

InOut Exchange パターン使用時の応答待ちタイムアウトを設定する (ミリ秒単位) 。

20000

long

requestTimeoutChecker Interval (advanced)

inOut エクスチェンジの requestTimeoutCheckerInterval を設定する

1000

long

transferException (advanced)

true の場合、コンシューマー側で inOut Exchange が失敗し、原因となった例外がレスポンスで返されます。

false

boolean

publisher Acknowledgements (producer)

true の場合、メッセージはパブリッシャーの確認をオンにしてパブリッシュされます。

false

boolean

publisher AcknowledgementsTimeout (producer)

RabbitMQ サーバーからの basic.ack 応答を待機する時間 (ミリ秒)

 

long

guaranteedDeliveries (producer)

true の場合、メッセージを配信できず (basic.return)、メッセージが必須としてマークされている場合に例外が出力されます。この場合、PublisherAcknowledgement もアクティブ化されます。パブリッシャーの確認も参照してください - メッセージはいつ確認されますか。

false

boolean

mandatory (producer)

このフラグは、メッセージをキューにルーティングできない場合の対応方法をサーバーに指示します。このフラグが設定されている場合、サーバーは Return メソッドでルーティング不可能なメッセージを返します。このフラグがゼロの場合、サーバーはメッセージを通知せずにドロップします。ヘッダーが rabbitmq.MANDATORY である場合、このオプションはオーバーライドされます。

false

boolean

immediate (producer)

このフラグは、メッセージをすぐにキューコンシューマーにルーティングできない場合の対応方法をサーバーに指示します。このフラグが設定されている場合、サーバーは Return メソッドで配信不能メッセージを返します。このフラグがゼロの場合、サーバーはメッセージをキューに入れますが、メッセージが消費されるという保証はありません。ヘッダーが rabbitmq.IMMEDIATE である場合、このオプションはオーバーライドされます。

false

boolean

args (advanced)

さまざまな RabbitMQ の概念を設定するための引数を指定します。それぞれに異なる接頭辞が必要です: Exchange: arg.exchange。Queue: arg.queue.Binding: arg.binding.たとえば、メッセージ ttl 引数でキューを宣言するには: http://localhost:5672/exchange/queueargs=arg.queue.x-message-ttl=60000

 

Map

clientProperties (advanced)

接続クライアントプロパティー (サーバーとのネゴシエーションで使用されるクライアント情報)

 

Map

sslProtocol (security)

接続時に SSL を有効にします。受け入れられる値は true、TLS および SSLv3 です。

 

String

trustManager (security)

SSL トラストマネージャーを設定します。このオプションを有効にするには、SSL を有効にする必要があります。

 

TrustManager

autoAck (consumer)

メッセージを自動確認する必要がある場合

true

boolean

autoDelete (Common)

true の場合、エクスチェンジは使用されなくなった時点で削除されます

true

boolean

durable (Common)

永続的なエクスチェンジを宣言している場合 (エクスチェンジはサーバーの再起動後も存続します)

true

boolean

exclusive (Common)

排他キューは、現在の接続によってのみアクセスでき、その接続が閉じると削除されます。

false

boolean

exclusiveConsumer (consumer)

キューへの排他的アクセスを要求します (つまり、このコンシューマーのみがキューにアクセスできます)。これは、存続期間の長い共有キューに一時的に 1 つのコンシューマーのみがアクセスできるようにする場合に役立ちます。

false

boolean

passive (Common)

パッシブキューは、RabbitMQ ですでに使用可能なキューに依存します。

false

boolean

skipQueueDeclare (Common)

true の場合、プロデューサーはキューを宣言およびバインドしません。これは、既存のルーティングキーを介してメッセージを送信するために使用できます。

false

boolean

skipQueueBind (Common)

true の場合、キューは宣言後にエクスチェンジにバインドされません

false

boolean

skipExchangeDeclare (Common)

これは、交換ではなくキューを宣言する必要がある場合に使用できます。

false

boolean

declare (Common)

オプションが true の場合、camel はエクスチェンジとキューの名前を宣言し、それらをバインドします。オプションが false の場合、camel はサーバー上でエクスチェンジとキューの名前を宣言しません。

true

boolean

deadLetterExchange (common)

デッドレターエクスチェンジの名前

 

String

deadLetterQueue (common)

配信不能キューの名前

 

String

deadLetterRoutingKey (common)

デッドレターエクスチェンジのルーティングキー

 

String

deadLetterExchangeType (common)

デッドレターエクスチェンジの種類

直接的な

String

allowNullHeaders (producer)

null 値をヘッダーに渡すことを許可する

false

boolean

resolveProperty Placeholders (advanced)

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

true

boolean

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

rabbitmq:exchangeName

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

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

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

exchangeName

必須 エクスチェンジ名によって、どのエクスチェンジで作成されたメッセージが送信されるかが決まります。コンシューマーの場合、エクスチェンジ名はキューがどのエクスチェンジにバインドするかを決定します。

 

String

272.2.2. クエリーパラメーター(62 個のパラメーター):

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

addresses (Common)

このオプションが設定されている場合、camel-rabbitmq はオプションアドレスの設定に基づいて接続を作成しようとします。アドレスの値は、server1:12345、server2:12345 のような文字列です。

 

Address[]

autoDelete (Common)

true の場合、エクスチェンジは使用されなくなった時点で削除されます

true

boolean

connectionFactory (common)

カスタム RabbitMQ 接続ファクトリーを使用するには。このオプションが設定されている場合、URI に設定されているすべての接続オプション (connectionTimeout、requestedChannelMax など) は使用されません。

 

ConnectionFactory

deadLetterExchange (common)

デッドレターエクスチェンジの名前

 

String

deadLetterExchangeType (common)

デッドレターエクスチェンジの種類

直接的な

String

deadLetterQueue (common)

配信不能キューの名前

 

String

deadLetterRoutingKey (common)

デッドレターエクスチェンジのルーティングキー

 

String

declare (Common)

オプションが true の場合、camel はエクスチェンジとキューの名前を宣言し、それらをバインドします。オプションが false の場合、camel はサーバー上でエクスチェンジとキューの名前を宣言しません。

true

boolean

durable (Common)

永続的なエクスチェンジを宣言している場合 (エクスチェンジはサーバーの再起動後も存続します)

true

boolean

exchangeType (Common)

ダイレクトやトピックなどのエクスチェンジタイプ。

直接的な

String

exclusive (Common)

排他キューは、現在の接続によってのみアクセスでき、その接続が閉じると削除されます。

false

boolean

hostname (common)

実行中の rabbitmq インスタンスまたはクラスターのホスト名。

 

String

passive (Common)

パッシブキューは、RabbitMQ ですでに使用可能なキューに依存します。

false

boolean

portNumber (Common)

実行中の rabbitmq インスタンスまたはクラスターを持つホストのポート番号。デフォルト値は 5672 です。

 

int

queue (Common)

メッセージを受信するキュー

 

String

routingKey (Common)

コンシューマーキューをエクスチェンジにバインドするときに使用するルーティングキー。プロデューサールーティングキーの場合は、ヘッダー rabbitmq.ROUTING_KEY を設定します。

 

String

skipExchangeDeclare (Common)

これは、交換ではなくキューを宣言する必要がある場合に使用できます。

false

boolean

skipQueueBind (Common)

true の場合、キューは宣言後にエクスチェンジにバインドされません

false

boolean

skipQueueDeclare (Common)

true の場合、プロデューサーはキューを宣言およびバインドしません。これは、既存のルーティングキーを介してメッセージを送信するために使用できます。

false

boolean

vhost (Common)

チャネルの仮想ホスト

/

String

autoAck (consumer)

メッセージを自動確認する必要がある場合

true

boolean

bridgeErrorHandler (consumer)

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

false

boolean

concurrentConsumers (consumer)

ブローカーから消費するときの同時コンシューマーの数。(たとえば、JMS コンポーネントの同じオプションと同様)。

1

int

exclusiveConsumer (consumer)

キューへの排他的アクセスを要求します (つまり、このコンシューマーのみがキューにアクセスできます)。これは、存続期間の長い共有キューに一時的に 1 つのコンシューマーのみがアクセスできるようにする場合に役立ちます。

false

boolean

prefetchCount (consumer)

サーバーが配信するメッセージの最大数。無制限の場合は 0。prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります。

 

int

prefetchEnabled (consumer)

RabbitMQConsumer 側でサービス品質を有効にします。prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります。

false

boolean

prefetchGlobal (consumer)

各コンシューマーではなく、チャネル全体に設定を適用する場合 prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります

false

boolean

prefetchSize (consumer)

サーバーが配信するコンテンツの最大量 (オクテットで測定)。無制限の場合は 0。prefetchSize、prefetchCount、prefetchGlobal のオプションを同時に指定する必要があります。

 

int

exceptionHandler (consumer)

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

 

ExceptionHandler

exchangePattern (consumer)

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

 

ExchangePattern

threadPoolSize (consumer)

コンシューマーは、固定数のスレッドで Thread Pool Executor を使用します。この設定により、そのスレッド数を設定できます。

10

int

allowNullHeaders (producer)

null 値をヘッダーに渡すことを許可する

false

boolean

bridgeEndpoint (producer)

bridgeEndpoint が true の場合、プロデューサーは rabbitmq.EXCHANGE_NAME と rabbitmq.ROUTING_KEY のメッセージヘッダーを無視します。

false

boolean

channelPoolMaxSize (producer)

プールで開かれているチャネルの最大数を取得する

10

int

channelPoolMaxWait (producer)

プールからのチャネルを待機する最大ミリ秒数を設定します

1000

long

guaranteedDeliveries (producer)

true の場合、メッセージを配信できず (basic.return)、メッセージが必須としてマークされている場合に例外が出力されます。この場合、PublisherAcknowledgement もアクティブ化されます。パブリッシャーの確認も参照してください - メッセージはいつ確認されますか。

false

boolean

immediate (producer)

このフラグは、メッセージをすぐにキューコンシューマーにルーティングできない場合の対応方法をサーバーに指示します。このフラグが設定されている場合、サーバーは Return メソッドで配信不能メッセージを返します。このフラグがゼロの場合、サーバーはメッセージをキューに入れますが、メッセージが消費されるという保証はありません。ヘッダーが rabbitmq.IMMEDIATE である場合、このオプションはオーバーライドされます。

false

boolean

mandatory (producer)

このフラグは、メッセージをキューにルーティングできない場合の対応方法をサーバーに指示します。このフラグが設定されている場合、サーバーは Return メソッドでルーティング不可能なメッセージを返します。このフラグがゼロの場合、サーバーはメッセージを通知せずにドロップします。ヘッダーが rabbitmq.MANDATORY である場合、このオプションはオーバーライドされます。

false

boolean

publisherAcknowledgements (producer)

true の場合、メッセージはパブリッシャーの確認をオンにしてパブリッシュされます。

false

boolean

publisherAcknowledgements Timeout (producer)

RabbitMQ サーバーからの basic.ack 応答を待機する時間 (ミリ秒)

 

long

args (advanced)

さまざまな RabbitMQ の概念を設定するための引数を指定します。それぞれに異なる接頭辞が必要です: Exchange: arg.exchange。Queue: arg.queue.Binding: arg.binding.たとえば、メッセージ ttl 引数でキューを宣言するには: http://localhost:5672/exchange/queueargs=arg.queue.x-message-ttl=60000

 

Map

automaticRecoveryEnabled (advanced)

接続の自動回復を有効にします (接続のシャットダウンがアプリケーションによって開始されない場合に自動回復を実行する接続の実装を使用します)

 

Boolean

bindingArgs (advanced)

非推奨 declare=true の場合にキューバインディングパラメーターを設定するためのキー/値引数

 

Map

clientProperties (advanced)

接続クライアントプロパティー (サーバーとのネゴシエーションで使用されるクライアント情報)

 

Map

connectionTimeout (advanced)

Connection timeout

60000

int

exchangeArgs (advanced)

非推奨 declare=true の場合にエクスチェンジパラメーターを設定するためのキー/値引数

 

Map

exchangeArgsConfigurer (advanced)

非推奨 Channel.exchangeDeclare でエクスチェンジ引数を設定するためのコンフィギュアラーを設定します

 

ArgsConfigurer

networkRecoveryInterval (advanced)

ミリ秒単位のネットワーク回復間隔 (ネットワーク障害からの回復時に使用される間隔)

5000

Integer

queueArgs (advanced)

非推奨 declare=true の場合にキューパラメーターを設定するためのキー/値引数

 

Map

queueArgsConfigurer (advanced)

非推奨 Channel.queueDeclare でキュー引数を設定するためのコンフィギュアラーを設定します

 

ArgsConfigurer

requestedChannelMax (advanced)

接続要求されたチャネルの最大数 (提供されるチャネルの最大数)

2047

int

requestedFrameMax (advanced)

接続要求フレーム最大 (提供されるフレームの最大サイズ)

0

int

requestedHeartbeat (advanced)

接続要求されたハートビート (提供される秒単位のハートビート)

60

int

requestTimeout (advanced)

InOut Exchange パターン使用時の応答待ちタイムアウトを設定する (ミリ秒単位) 。

20000

long

requestTimeoutChecker Interval (advanced)

inOut エクスチェンジの requestTimeoutCheckerInterval を設定する

1000

long

synchronous (advanced)

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

false

boolean

topologyRecoveryEnabled (advanced)

接続トポロジーの回復を有効にします (トポロジーの回復を実行する必要があります)。

 

Boolean

transferException (advanced)

true の場合、コンシューマー側で inOut Exchange が失敗し、原因となった例外がレスポンスで返されます。

false

boolean

password (security)

認証アクセス用のパスワード

guest

String

sslProtocol (security)

接続時に SSL を有効にします。受け入れられる値は true、TLS および SSLv3 です。

 

String

trustManager (security)

SSL トラストマネージャーを設定します。このオプションを有効にするには、SSL を有効にする必要があります。

 

TrustManager

username (security)

認証アクセスの場合のユーザー名

guest

String

Red Hat logoGithubRedditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

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

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

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

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

会社概要

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

© 2024 Red Hat, Inc.