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

送信チャネルアダプター

次の例は、AMQP 送信チャネルアダプターの使用可能なプロパティを示しています。

Java DSL
Java
XML

@Bean
public IntegrationFlow amqpOutbound(AmqpTemplate amqpTemplate,
        MessageChannel amqpOutboundChannel) {
    return IntegrationFlow.from(amqpOutboundChannel)
            .handle(Amqp.outboundAdapter(amqpTemplate)
                        .routingKey("queue1")) // default exchange - route to queue 'queue1'
            .get();
}

@Bean
@ServiceActivator(inputChannel = "amqpOutboundChannel")
public AmqpOutboundEndpoint amqpOutbound(AmqpTemplate amqpTemplate) {
    AmqpOutboundEndpoint outbound = new AmqpOutboundEndpoint(amqpTemplate);
    outbound.setRoutingKey("queue1"); // default exchange - route to queue 'queue1'
    return outbound;
}

@Bean
public MessageChannel amqpOutboundChannel() {
    return new DirectChannel();
}

<int-amqp:outbound-channel-adapter id="outboundAmqp"             (1)
                               channel="outboundChannel"         (2)
                               amqp-template="myAmqpTemplate"    (3)
                               exchange-name=""                  (4)
                               exchange-name-expression=""       (5)
                               order="1"                         (6)
                               routing-key=""                    (7)
                               routing-key-expression=""         (8)
                               default-delivery-mode""           (9)
                               confirm-correlation-expression="" (10)
                               confirm-ack-channel=""            (11)
                               confirm-nack-channel=""           (12)
                               confirm-timeout=""                (13)
                               wait-for-confirm=""               (14)
                               return-channel=""                 (15)
                               error-message-strategy=""         (16)
                               header-mapper=""                  (17)
                               mapped-request-headers=""         (18)
                               lazy-connect="true"               (19)
                               multi-send="false"/>              (20)

1	このアダプターの一意の ID。オプション。
2	メッセージを AMQP 交換に変換して公開するために送信するメッセージチャネル。必須。
3	構成された AMQP テンプレートへの Bean 参照。オプション（デフォルトは `amqpTemplate`）。
4	メッセージの送信先の AMQP 交換の名前。指定しない場合、メッセージはデフォルトの名前のない交換に送信されます。"exchange-name-expression" と相互に排他的です。オプション。
5	メッセージがルートオブジェクトとして送信される AMQP 交換の名前を決定するために評価される SpEL 式。指定しない場合、メッセージはデフォルトの名前のない交換に送信されます。"exchange-name" と相互に排他的。オプション。
6	複数のコンシューマーが登録されている場合のこのコンシューマーの順序。これにより、負荷分散とフェイルオーバーが可能になります。オプション（デフォルトは `Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]`）。
7	メッセージを送信するときに使用する固定ルーティングキー。デフォルトでは、これは空の `String` です。"routing-key-expression" と相互に排他的です。オプション。
8	メッセージをルートオブジェクトとして使用してメッセージを送信するときに使用するルーティングキーを決定するために評価される SpEL 式（ "payload.key" など）。デフォルトでは、これは空の `String` です。「ルーティングキー」と相互に排他的。オプション。
9	メッセージのデフォルト配信モード: `PERSISTENT` または `NON_PERSISTENT` `header-mapper` が配信モードを設定するとオーバーライドされます。Spring Integration メッセージヘッダー `amqp_deliveryMode` が存在する場合、`DefaultHeaderMapper` は値を設定します。この属性が指定されておらず、ヘッダーマッパーが設定しない場合、デフォルトは `RabbitTemplate` によって使用される基になる Spring AMQP `MessagePropertiesConverter` に依存します。それがまったくカスタマイズされていない場合、デフォルトは `PERSISTENT` です。オプション。
10	相関データを定義する式。提供される場合、これは、パブリッシャーの確認を受信するように基盤となる AMQP テンプレートを構成します。専用の `RabbitTemplate` と、`publisherConfirms` プロパティが `true` に設定された `CachingConnectionFactory` が必要です。パブリッシャーの確認を受信して相関データを提供すると、確認の種類に応じて、`confirm-ack-channel` または `confirm-nack-channel` のいずれかに書き込まれます。確認のペイロードは、この式で定義されている相関データです。メッセージには、'amqp_publishConfirm' ヘッダーが `true` （`ack`）または `false` （`nack`）に設定されています。例: `headers['myCorrelationData']` および `payload`。バージョン 4.1 では、`amqp_publishConfirmNackCause` メッセージヘッダーが導入されました。これには、発行者の確認用の「ナック」の `cause` が含まれています。バージョン 4.2 以降、式が `Message<?>` インスタンス（`#this` など）に解決される場合、`ack`/`nack` チャネルで発行されるメッセージはそのメッセージに基づいており、追加のヘッダーが追加されています。以前は、型に関係なく、ペイロードとして相関データを使用して新しいメッセージが作成されていました。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション。
11	ポジティブ（`ack`）パブリッシャーが確認するチャネルが送信されます。ペイロードは、`confirm-correlation-expression` によって定義された相関データです。式が `#root` または `#this` の場合、メッセージは元のメッセージから構築され、`amqp_publishConfirm` ヘッダーは `true` に設定されます。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション（デフォルトは `nullChannel`）。
12	否定的な（`nack`）パブリッシャー確認の送信先のチャネル。ペイロードは、`confirm-correlation-expression` によって定義された相関データです（`ErrorMessageStrategy` が構成されていない場合）。式が `#root` または `#this` の場合、メッセージは元のメッセージから構築され、`amqp_publishConfirm` ヘッダーは `false` に設定されます。`ErrorMessageStrategy` がある場合、メッセージは `NackedAmqpMessageException` ペイロードを持つ `ErrorMessage` です。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション（デフォルトは `nullChannel`）。
13	設定すると、この時間内にパブリッシャー確認が受信されない場合、アダプターは否定応答（nack）を合成します（ミリ秒単位）。保留中の確認はこの値の 50% ごとにチェックされるため、nack が送信される実際の時間は 1x と 1.5x の間になります。パブリッシャーの確認と return の代替メカニズムも参照してください。デフォルトはなし（nack は生成されません）。
14	true に設定すると、呼び出しスレッドはブロックされ、パブリッシャーの確認を待ちます。これには、確認用に構成された `RabbitTemplate` と `confirm-correlation-expression` が必要です。スレッドは最大 `confirm-timeout` (デフォルトでは 5 秒) までブロックされます。タイムアウトが発生すると、`MessageTimeoutException` がスローされます。return が有効で、メッセージが返された場合、確認を待っている間にその他の例外が発生した場合は、適切なメッセージとともに `MessageHandlingException` がスローされます。
15	返されたメッセージが送信されるチャネル。指定すると、基になる AMQP テンプレートは、配信不能メッセージをアダプターに返すように構成されます。`ErrorMessageStrategy` が構成されていない場合、メッセージは AMQP から受信したデータと次の追加ヘッダー `amqp_returnReplyCode`、`amqp_returnReplyText`、`amqp_returnExchange`、`amqp_returnRoutingKey` から構成されます。`ErrorMessageStrategy` がある場合、メッセージは `ReturnedAmqpMessageException` ペイロードを持つ `ErrorMessage` です。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション。
16	返されたメッセージまたは否定応答メッセージを送信するときに `ErrorMessage` インスタンスを構築するために使用される `ErrorMessageStrategy` 実装への参照。
17	AMQP メッセージを送信するときに使用する `AmqpHeaderMapper` への参照。デフォルトでは、標準の AMQP プロパティ（`contentType` など）のみが Spring Integration `MessageHeaders` にコピーされます。デフォルトの `DefaultAmqpHeaderMapper` では、ユーザー定義のヘッダーはメッセージにコピーされません。'request-header-names' が指定されている場合は許可されません。オプション。
18	`MessageHeaders` から AMQP メッセージにマッピングされる AMQP ヘッダーの名前のコンマ区切りリスト。"header-mapper" 参照が提供されている場合は許可されません。このリストの値は、ヘッダー名と照合する単純なパターンにすることもできます（例: `""` または `"thing1, thing2"` または `"*thing1"`）。
19	`false` に設定すると、エンドポイントはアプリケーションコンテキストの初期化中にブローカーへの接続を試行します。これにより、不良構成の「フェイルファースト」検出が可能になりますが、ブローカーがダウンしていると初期化が失敗します。`true` （デフォルト）の場合、最初のメッセージが送信されたときに接続が確立されます（他のコンポーネントが接続を確立したためにすでに存在しない場合）。
20	`true` に設定すると、型 `Iterable<Message<?>>` のペイロードは、単一の `RabbitTemplate` 呼び出しのスコープ内の同じチャネルで個別のメッセージとして送信されます。`RabbitTemplate` が必要です。`wait-for-confirms` が true の場合、メッセージが送信された後に `RabbitTemplate.waitForConfirmsOrDie()` が呼び出されます。トランザクションテンプレートでは、送信は新しいトランザクションまたはすでに開始されているトランザクション（存在する場合）で実行されます。

return-channel

return-channel を使用するには、mandatory プロパティが true に設定された RabbitTemplate と、publisherReturns プロパティが true に設定された CachingConnectionFactory が必要です。リターンで複数の送信エンドポイントを使用する場合、エンドポイントごとに個別の RabbitTemplate が必要です。