出站通道适配器

以下示例显示了 AMQP 出站通道适配器的可用属性：spring-doc.cadn.net.cn

@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 交换的名称。如果未提供，则消息将发送到默认的 no-name 交换。与 'exchange-name-expression' 互斥。自选。
5	一个 SPEL 表达式，用于确定消息发送到的 AMQP 交换的名称，并将消息作为根对象。如果未提供，则消息将发送到默认的 no-name 交换。与 'exchange-name' 互斥。自选。
6	注册多个使用者时此使用者的顺序，从而启用负载均衡和故障转移。可选（默认为`Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]`).
7	发送消息时使用的固定 routing-key。默认情况下，这是一个空的`String`. 与 'routing-key-expression' 互斥。自选。
8	一个 SPEL 表达式，用于确定发送消息时要使用的路由键，并将消息作为根对象（例如，'payload.key'）。默认情况下，这是一个空的`String`. 与 'routing-key' 互斥。自选。
9	消息的默认传递模式：`PERSISTENT`或`NON_PERSISTENT`. 如果`header-mapper`设置传递模式。如果 Spring Integration 消息标头`amqp_deliveryMode`存在时，`DefaultHeaderMapper`设置值。如果未提供此属性并且 Headers 映射器未设置它，则默认值取决于底层的 Spring AMQP`MessagePropertiesConverter`由`RabbitTemplate`. 如果根本没有自定义，则默认值为`PERSISTENT`. 自选。
10	定义相关数据的表达式。如果提供，这会将底层 AMQP 模板配置为接收发布者确认。需要专用的`RabbitTemplate`以及`CachingConnectionFactory`使用`publisherConfirms`属性设置为`true`. 收到发布者确认并提供关联数据后，该确认将写入`confirm-ack-channel`或`confirm-nack-channel`，具体取决于确认类型。确认的有效负载是相关数据，如此表达式所定义。邮件的 'amqp_publishConfirm' 报头设置为`true` (`ack`）或`false` (`nack`). 例子：`headers['myCorrelationData']`和`payload`. 版本 4.1 引入了`amqp_publishConfirmNackCause`消息标头。它包含`cause`的 'nack' 用于出版商确认。从版本 4.2 开始，如果表达式解析为`Message<?>`实例（例如`#this`），则在`ack`/`nack`channel 基于该消息，并添加了其他标头。以前，无论类型如何，都会使用关联数据作为其负载创建新消息。另请参阅发布者确认和返回的替代机制。自选。
11	正（`ack`）发布者确认。有效负载是由`confirm-correlation-expression`. 如果表达式为`#root`或`#this`，则消息是从原始消息构建的，其中`amqp_publishConfirm`header 设置为`true`. 另请参阅发布者确认和返回的替代机制。可选（默认值为`nullChannel`).
12	负数（`nack`）发布者确认。有效负载是由`confirm-correlation-expression`（如果没有`ErrorMessageStrategy`configured）。如果表达式为`#root`或`#this`，则消息是从原始消息构建的，其中`amqp_publishConfirm`header 设置为`false`. 当存在`ErrorMessageStrategy`，则消息是一个`ErrorMessage`替换为`NackedAmqpMessageException`有效载荷。另请参阅发布者确认和返回的替代机制。可选（默认值为`nullChannel`).
13	设置后，如果在此时间（以毫秒为单位）内未收到发布者确认，则适配器将合成否定确认（nack）。待处理确认每检查一次此值的 50%，因此发送 nack 的实际时间将介于此值的 1 倍到 1.5 倍之间。另请参阅发布者确认和返回的替代机制。默认无（不会生成 nack）。
14	当设置为 true 时，调用线程将阻塞，等待发布者确认。这需要`RabbitTemplate`为 Confirms 以及`confirm-correlation-expression`. 线程将阻塞长达`confirm-timeout`（或默认为 5 秒）。如果发生超时，则`MessageTimeoutException`将被抛出。如果启用了返回并返回了一条消息，或者在等待确认时发生任何其他异常，则`MessageHandlingException`将引发，并显示相应的消息。
15	返回的消息发送到的通道。如果提供，则底层 AMQP 模板配置为将无法传递的消息返回给适配器。当没有`ErrorMessageStrategy`配置后，该消息是根据从 AMQP 接收的数据构建的，并具有以下附加标头：`amqp_returnReplyCode`,`amqp_returnReplyText`,`amqp_returnExchange`,`amqp_returnRoutingKey`. 当存在`ErrorMessageStrategy`，则消息是一个`ErrorMessage`替换为`ReturnedAmqpMessageException`有效载荷。另请参阅发布者确认和返回的替代机制。自选。
16	对`ErrorMessageStrategy`用于构建的 implementation used to build`ErrorMessage`实例。
17	对`AmqpHeaderMapper`在发送 AMQP 消息时使用。默认情况下，只有标准的 AMQP 属性（例如`contentType`）复制到 Spring 集成`MessageHeaders`. 默认的'DefaultAmqpHeaderMapper'不会将任何用户定义的 Headers 复制到消息中。如果提供了 'request-header-names'，则不允许。自选。
18	要从`MessageHeaders`添加到 AMQP 消息中。如果提供了 'header-mapper' 引用，则不允许。此列表中的值也可以是与 Headers 名称匹配的简单模式（例如或`"""thing1, thing2"`或`"*thing1"`).
19	当设置为`false`时，终端节点将尝试在应用程序上下文初始化期间连接到代理。这允许对错误配置进行 “fail fast” 检测，但如果 broker 宕机，也会导致初始化失败。什么时候`true`（默认值），则在发送第一条消息时建立连接（如果连接尚不存在，因为其他组件建立了连接）。
20	当设置为`true`、类型为`Iterable<Message<?>>`将作为离散消息在同一个通道上的单个`RabbitTemplate`调用。需要`RabbitTemplate`. 什么时候`wait-for-confirms`为 true，`RabbitTemplate.waitForConfirmsOrDie()`在发送消息后调用。使用事务模板，将在新事务或已启动的事务（如果存在）中执行发送。

return-channel （返回通道）

使用return-channel需要RabbitTemplate使用mandatory属性设置为true以及CachingConnectionFactory使用publisherReturns属性设置为true. 当使用多个带有返回的出站终端节点时，单独的RabbitTemplate每个终端节点都需要。spring-doc.cadn.net.cn