出站网关

以下清单显示了 AMQP 出站网关的可能属性：spring-doc.cn

@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 交换的名称。 如果未提供，则消息将发送到默认的 no-name cxchange。 与 'exchange-name-expression' 互斥。 自选。
5 一个 SPEL 表达式，用于确定应将消息发送到的 AMQP 交换的名称，并将消息作为根对象。 如果未提供，则消息将发送到默认的 no-name 交换。 与 'exchange-name' 互斥。 自选。
6 注册多个使用者时此使用者的顺序，从而启用负载均衡和故障转移。 可选 （默认为 ）。Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]
7 从 AMQP 队列接收回复并进行转换后，应将回复发送到的消息通道。 自选。
8 网关在向 发送回复消息时等待的时间。 这仅适用于 can 阻止的情况，例如容量限制当前已满的 a。 默认为 infinity。reply-channelreply-channelQueueChannel
9 When 时，如果属性中未收到回复消息，则网关将引发异常。 默认为 。trueAmqpTemplate’s `replyTimeouttrue
10 发送消息时使用的。 默认情况下，这是一个空的 . 与 'routing-key-expression' 互斥。 自选。routing-keyString
11 一个 SPEL 表达式，用于确定发送消息时使用的表达式，并将消息作为根对象（例如，'payload.key'）。 默认情况下，这是一个空的 . 与 'routing-key' 互斥。 自选。routing-keyString
12 邮件的默认传递模式：或 . 如果设置了传递模式，则被覆盖。 如果存在 Spring Integration 消息标头，则设置值。 如果未提供此属性并且标头映射器未设置它，则默认值取决于 . 如果根本没有自定义，则默认值为 。 自选。PERSISTENTNON_PERSISTENTheader-mapperamqp_deliveryModeDefaultHeaderMapperMessagePropertiesConverterRabbitTemplatePERSISTENT
13 从 4.2 版本开始。 定义关联数据的表达式。 如果提供，这会将底层 AMQP 模板配置为接收发布者确认。 需要 dedicated 和 a，并将属性设置为 。 收到发布者确认并提供关联数据后，会将其写入 或 ，具体取决于确认类型。 确认的有效负载是此表达式定义的关联数据。 邮件的报头 'amqp_publishConfirm' 设置为 （） 或 （）。 为了确认， Spring Integration 提供了一个额外的 header 。 示例：和 . 如果表达式解析为实例（例如 ），则消息 / 通道上发出的 / 基于该消息，并添加了其他标头。 以前，无论类型如何，都会使用关联数据作为其负载创建新消息。 另请参阅发布者确认和返回的替代机制。 自选。RabbitTemplateCachingConnectionFactorypublisherConfirmstrueconfirm-ack-channelconfirm-nack-channeltrueackfalsenacknackamqp_publishConfirmNackCauseheaders['myCorrelationData']payloadMessage<?>#thisacknack
14 将肯定 （） 发布者确认发送到的渠道。 有效载荷是由 定义的相关数据。 如果表达式为 或 ，则消息是从原始消息构建的，标题设置为 。 另请参阅发布者确认和返回的替代机制。 可选（默认值为 ）。ackconfirm-correlation-expression#root#thisamqp_publishConfirmtruenullChannel
15 否定 （） 发布者确认发送到的渠道。 有效负载是由 （如果未配置） 定义的关联数据。 如果表达式为 或 ，则消息是从原始消息构建的，标题设置为 。 当存在 时，消息是具有有效负载的 an。 另请参阅发布者确认和返回的替代机制。 可选（默认值为 ）。nackconfirm-correlation-expressionErrorMessageStrategy#root#thisamqp_publishConfirmfalseErrorMessageStrategyErrorMessageNackedAmqpMessageExceptionnullChannel
16 设置后，如果在此时间（以毫秒为单位）内未收到发布者确认，网关将合成否定确认 （nack）。 待处理确认每检查一次此值的 50%，因此发送 nack 的实际时间将介于此值的 1 倍到 1.5 倍之间。 默认无（不会生成 nack）。
17 返回的消息发送到的通道。 如果提供，则底层 AMQP 模板配置为将无法传递的消息返回给适配器。 如果未配置，则根据从 AMQP 接收的数据构建消息，并具有以下附加标头： 、 、 和 。 当存在 时，消息是具有有效负载的 an。 另请参阅发布者确认和返回的替代机制。 自选。ErrorMessageStrategyamqp_returnReplyCodeamqp_returnReplyTextamqp_returnExchangeamqp_returnRoutingKeyErrorMessageStrategyErrorMessageReturnedAmqpMessageException
18 对用于在发送返回或否定确认消息时构建实例的实现的引用。ErrorMessageStrategyErrorMessage
19 设置为 时，端点将在应用程序上下文初始化期间尝试连接到代理。 这允许在代理关闭时通过记录错误消息来“快速失败”检测错误配置。 When （默认值），在发送第一条消息时建立连接（如果它尚不存在，因为其他组件建立了它）。falsetrue
return-channel （返回通道）

使用 a 需要 a 且 属性设置为 ，以及 a 且 属性设置为 。 当使用多个带返回的出站终端节点时，每个终端节点都需要一个单独的终端节点。return-channelRabbitTemplatemandatorytrueCachingConnectionFactorypublisherReturnstrueRabbitTemplatespring-doc.cn
底层的默认值为 5 秒。 如果需要更长的超时时间，则必须在 .AmqpTemplatereplyTimeouttemplate

请注意，出站适配器和出站网关配置之间的唯一区别是属性的设置。expectReplyspring-doc.cn