第271章 RabbitMQ コンポーネント

Camel バージョン 2.12 以降で利用可能

rabbitmq: コンポーネントを使用すると、RabbitMQ インスタンスからメッセージを生成および消費できます。このコンポーネントは、RabbitMQ AMQP クライアントを使用して、汎用 AMQP コンポーネントよりも純粋な RabbitMQ アプローチを提供します。

Maven ユーザーは、このコンポーネントの pom.xml に以下の依存関係を追加する必要があります。 

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-rabbitmq</artifactId>
    <version>x.x.x</version>
    <!-- use the same version as your Camel core version -->
</dependency>

271.1. URI 形式

古い構文は 非推奨 です: 

rabbitmq://hostname[:port]/exchangeName?[options]

代わりに、ホスト名とポートをコンポーネントレベルで設定するか、代わりに uri クエリーパラメーターとして指定できます。

新しい構文は次のとおりです。 

rabbitmq:exchangeName?[options]

hostname は 実行中の rabbitmq インスタンスまたはクラスターのホスト名です。ポートはオプションです。指定しない場合は、デフォルトで RabbitMQ クライアントのデフォルト (5672) になります。エクスチェンジ名によって、どのエクスチェンジで作成されたメッセージが送信されるかが決まります。コンシューマーの場合、エクスチェンジ名はキューがどのエクスチェンジにバインドするかを決定します。