270.2. オプション

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

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

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)

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

0

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

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

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

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

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

exchangeName

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

 

文字列

270.2.2. クエリーパラメーター (61 パラメーター)

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

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)

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

false

boolean

concurrentConsumers (consumer)

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

1

int

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 オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、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)

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

0

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

文字列

接続オプションの詳細については、http://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/ConnectionFactory.html および AMQP 仕様を参照してください。