最新の安定バージョンについては、Spring AMQP 4.1.1 を使用してください！

Spring Integration - リファレンス

リファレンスドキュメントのこのパートでは、Spring Integration プロジェクト内の AMQP サポートについて簡単に導入します。

導入

Spring Integration プロジェクトには、Spring AMQP プロジェクトを基盤とする AMQP チャネルアダプターとゲートウェイが含まれています。これらのアダプターは Spring Integration プロジェクトで開発およびリリースされています。Spring Integration では、「チャネルアダプター」は単方向（一方向）ですが、「ゲートウェイ」は双方向（リクエスト / レスポンス）です。受信チャネルアダプター、送信チャネルアダプター、受信ゲートウェイ、送信ゲートウェイを提供しています。

AMQP アダプターは Spring Integration リリースの一部であるため、ドキュメントは Spring Integration ディストリビューションの一部として入手できます。ここでは、主な機能の概要を簡単に説明します。詳細については、Spring Integration リファレンスガイドを参照してください。

受信チャネルアダプター

キューから AMQP メッセージを受信するには、<inbound-channel-adapter> を構成できます。次の例は、受信チャネルアダプターを構成する方法を示しています。

<amqp:inbound-channel-adapter channel="fromAMQP"
                              queue-names="some.queue"
                              connection-factory="rabbitConnectionFactory"/>

送信チャネルアダプター

AMQP メッセージを交換機に送信するには、<outbound-channel-adapter> を構成できます。オプションで、交換名に加えて「ルーティングキー」を指定できます。次の例は、送信チャネルアダプターを定義する方法を示しています。

<amqp:outbound-channel-adapter channel="toAMQP"
                               exchange-name="some.exchange"
                               routing-key="foo"
                               amqp-template="rabbitTemplate"/>

受信ゲートウェイ

キューから AMQP メッセージを受信し、その返信先アドレスに応答するには、<inbound-gateway> を構成できます。次の例は、受信ゲートウェイを定義する方法を示しています。

<amqp:inbound-gateway request-channel="fromAMQP"
                      reply-channel="toAMQP"
                      queue-names="some.queue"
                      connection-factory="rabbitConnectionFactory"/>

送信ゲートウェイ

AMQP メッセージを交換機に送信し、リモートクライアントからレスポンスを受信するには、<outbound-gateway> を構成できます。オプションで、交換名に加えて「ルーティングキー」を指定できます。次の例は、送信ゲートウェイを定義する方法を示しています。

<amqp:outbound-gateway request-channel="toAMQP"
                       reply-channel="fromAMQP"
                       exchange-name="some.exchange"
                       routing-key="foo"
                       amqp-template="rabbitTemplate"/>