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 仕様を参照してください。