このバージョンはまだ開発中であり、まだ安定しているとは見なされていません。最新の安定バージョンについては、Spring Integration 6.5.3 を使用してください！

送信ゲートウェイ

次のリストは、AMQP 送信ゲートウェイの可能なプロパティを示しています。

Java DSL
Java
XML

@Bean
public IntegrationFlow amqpOutbound(AmqpTemplate amqpTemplate) {
    return f -> f.handle(Amqp.outboundGateway(amqpTemplate)
                    .routingKey("foo")) // default exchange - route to queue 'foo'
            .get();
}

@MessagingGateway(defaultRequestChannel = "amqpOutbound.input")
public interface MyGateway {

    String sendToRabbit(String data);

}

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

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

@MessagingGateway(defaultRequestChannel = "amqpOutboundChannel")
public interface MyGateway {

    String sendToRabbit(String data);

}

<int-amqp:outbound-gateway id="outboundGateway"               (1)
                           request-channel="myRequestChannel" (2)
                           amqp-template=""                   (3)
                           exchange-name=""                   (4)
                           exchange-name-expression=""        (5)
                           order="1"                          (6)
                           reply-channel=""                   (7)
                           reply-timeout=""                   (8)
                           requires-reply=""                  (9)
                           routing-key=""                     (10)
                           routing-key-expression=""          (11)
                           default-delivery-mode""            (12)
                           confirm-correlation-expression=""  (13)
                           confirm-ack-channel=""             (14)
                           confirm-nack-channel=""            (15)
                           confirm-timeout=""                 (16)
                           return-channel=""                  (17)
                           error-message-strategy=""          (18)
                           lazy-connect="true" />             (19)

1	このアダプターの一意の ID。オプション。
2	メッセージを AMQP 交換に変換して公開するために送信されるメッセージチャネル。必須。
3	構成された AMQP テンプレートへの Bean 参照。オプション（デフォルトは `amqpTemplate`）。
4	メッセージの送信先となる AMQP 交換の名前。指定しない場合、メッセージはデフォルトの名前なしの cxchange に送信されます。"exchange-name-expression" と相互に排他的です。オプション。
5	メッセージをルートオブジェクトとして、メッセージの送信先 AMQP 交換の名前を決定するために評価される SpEL 式。指定しない場合、メッセージはデフォルトの名前のない交換に送信されます。"exchange-name" と相互に排他的。オプション。
6	複数のコンシューマーが登録されている場合のこのコンシューマーの順序。これにより、負荷分散とフェイルオーバーが可能になります。オプション（デフォルトは `Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]`）。
7	AMQP キューから受信して変換した後、応答が送信されるメッセージチャネル。オプション。
8	`reply-channel` に応答メッセージを送信するときにゲートウェイが待機する時間。これは、`reply-channel` がブロックできる場合にのみ適用されます。たとえば、容量制限が現在いっぱいの `QueueChannel` などです。デフォルトは無限大です。
9	`true` の場合、AmqpTemplate’s `replyTimeout プロパティ内で応答メッセージが受信されない場合、ゲートウェイは例外をスローします。デフォルトは `true` です。
10	メッセージを送信するときに使用する `routing-key`。デフォルトでは、これは空の `String` です。"routing-key-expression" と相互に排他的です。オプション。
11	A SpEL expression that is evaluated to determine the `routing-key` to use when sending messages, with the message as the root object (for example, 'payload.key'). By default, this is an empty `String`. Mutually exclusive with `routing-key`. Optional.
12	メッセージのデフォルト配信モード: `PERSISTENT` または `NON_PERSISTENT` `header-mapper` が配信モードを設定するとオーバーライドされます。Spring Integration メッセージヘッダー `amqp_deliveryMode` が存在する場合、`DefaultHeaderMapper` は値を設定します。この属性が指定されておらず、ヘッダーマッパーが設定しない場合、デフォルトは `RabbitTemplate` によって使用される基になる Spring AMQP `MessagePropertiesConverter` に依存します。それがまったくカスタマイズされていない場合、デフォルトは `PERSISTENT` です。オプション。
13	Since version 4.2. An expression defining correlation data. When provided, this configures the underlying AMQP template to receive publisher confirms. Requires a dedicated `RabbitTemplate` and a `CachingConnectionFactory` with the `publisherConfirms` property set to `true`. When a publisher `confirm` is received and correlation data is supplied, it is written to either the `confirm-ack-channel` or the `confirm-nack-channel`, depending on the confirmation type. The payload of the `confirm` is the correlation data, as defined by this expression. The message has a header 'amqp_publishConfirm' set to `true` (`ack`) or `false` (`nack`). For `nack` confirmations, Spring Integration provides an additional header `amqp_publishConfirmNackCause`. Examples: `headers['myCorrelationData']` and `payload`. If the expression resolves to a `Message<?>` instance (such as `#this`), the message emitted on the `ack`/`nack` channel is based on that message, with the additional headers added. Previously, a new message was created with the correlation data as its payload, regardless of type. Also see パブリッシャーの確認と return の代替メカニズム . Optional.
14	肯定的な（`ack`）パブリッシャー確認が送信されるチャネル。ペイロードは、`confirm-correlation-expression` によって定義された相関データです。式が `#root` または `#this` の場合、メッセージは元のメッセージから構築され、`amqp_publishConfirm` ヘッダーは `true` に設定されます。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション（デフォルトは `nullChannel`）。
15	否定的な（`nack`）パブリッシャー確認の送信先のチャネル。ペイロードは、`confirm-correlation-expression` によって定義された相関データです（`ErrorMessageStrategy` が構成されていない場合）。式が `#root` または `#this` の場合、メッセージは元のメッセージから構築され、`amqp_publishConfirm` ヘッダーは `false` に設定されます。`ErrorMessageStrategy` がある場合、メッセージは `NackedAmqpMessageException` ペイロードを持つ `ErrorMessage` です。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション（デフォルトは `nullChannel`）。
16	設定すると、パブリッシャーがミリ秒単位のこの時間内に確認を受信しない場合、ゲートウェイは否定応答（nack）を合成します。保留確認は、この値の 50% ごとにチェックされるため、ナックが送信される実際の時間は、この値 1x と 1.5x の間になります。デフォルトなし（ナックは生成されません）。
17	返されたメッセージが送信されるチャネル。指定すると、基になる AMQP テンプレートは、配信不能メッセージをアダプターに返すように構成されます。`ErrorMessageStrategy` が構成されていない場合、メッセージは AMQP から受信したデータと次の追加ヘッダー `amqp_returnReplyCode`、`amqp_returnReplyText`、`amqp_returnExchange`、`amqp_returnRoutingKey` から構成されます。`ErrorMessageStrategy` がある場合、メッセージは `ReturnedAmqpMessageException` ペイロードを持つ `ErrorMessage` です。パブリッシャーの確認と return の代替メカニズムも参照してください。オプション。
18	返されたメッセージまたは否定応答メッセージを送信するときに `ErrorMessage` インスタンスを構築するために使用される `ErrorMessageStrategy` 実装への参照。
19	`false` に設定すると、エンドポイントはアプリケーションコンテキストの初期化中にブローカーへの接続を試行します。これにより、ブローカがダウンしている場合にエラーメッセージを記録することにより、不正な構成の「フェイルファースト」検出が可能になります。`true` （デフォルト）の場合、最初のメッセージが送信されたときに接続が確立されます（他のコンポーネントが接続を確立したためにすでに存在しない場合）。

return-channel

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

基礎となる AmqpTemplate のデフォルトの replyTimeout は 5 秒です。より長いタイムアウトが必要な場合は、template で設定する必要があります。

送信アダプターと送信ゲートウェイの構成の唯一の違いは、expectReply プロパティの設定であることに注意してください。