出站通道适配器

以下示例显示了 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	一个 SpEL 表达式，该表达式用于确定将消息发送到的 AMQP 交换机的名称，其中消息作为根对象。如果未提供，则消息将发送到默认的无名称交换机。与“exchange-name”互斥。可选。
6	当注册多个使用者时，此使用者的顺序，从而启用负载均衡和故障转移。可选（默认为 `Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]`）。
7	发送消息时要使用的固定路由密钥。默认情况下，这是一个空 `String`。与“routing-key-expression”互斥。可选。
8	一个 SpEL 表达式，该表达式用于确定发送消息时要使用的路由密钥，其中消息作为根对象（例如，“payload.key”）。默认情况下，这是一个空 `String`。与“routing-key”互斥。可选。
9	消息的默认传递模式：`PERSISTENT` 或 `NON_PERSISTENT`。如果 `header-mapper` 设置了传递模式，则会被覆盖。如果 Spring 集成消息标头 `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` 消息标头。它包含发布者确认“nack”的`cause`。从版本 4.2 开始，如果表达式解析为 `Message<?>` 实例（例如 `#this`），则在 `ack`/`nack` 通道上发出的消息将基于该消息，并添加了额外的标头。以前，无论类型如何，都会创建一个新消息，并将相关数据作为其有效负载。另请参阅发布者确认和返回的替代机制。可选。
11	将正（`ack`）发布者确认发送到的通道。有效负载是由 `confirm-correlation-expression` 定义的相关数据。如果表达式为 `#root` 或 `#this`，则消息将根据原始消息构建，并将其 `amqp_publishConfirm` 标头设置为 `true`。另请参阅发布者确认和返回的替代机制。可选（默认为 `nullChannel`）。
12	将负（`nack`）发布者确认发送到的通道。有效负载是由 `confirm-correlation-expression` 定义的相关数据（如果未配置 `ErrorMessageStrategy`）。如果表达式为 `#root` 或 `#this`，则消息将根据原始消息构建，并将其 `amqp_publishConfirm` 标头设置为 `false`。当存在 `ErrorMessageStrategy` 时，消息为 `ErrorMessage`，其有效负载为 `NackedAmqpMessageException`。另请参阅发布者确认和返回的替代机制。可选（默认为 `nullChannel`）。
13	设置后，如果在毫秒数内未收到发布者确认，则适配器将合成负确认（nack）。每隔此值的 50% 检查挂起的确认，因此发送 nack 的实际时间将介于此值的 1 倍和 1.5 倍之间。另请参阅发布者确认和返回的替代机制。默认无（不会生成 nack）。
14	设置为 true 时，调用线程将阻塞，等待发布者确认。这需要一个配置了确认的 `RabbitTemplate` 以及一个 `confirm-correlation-expression`。线程将阻塞最多 `confirm-timeout`（或默认 5 秒）。如果发生超时，将抛出 `MessageTimeoutException`。如果启用了返回并且消息已返回，或者在等待确认期间发生任何其他异常，则将抛出 `MessageHandlingException`，并显示相应的错误消息。
15	将返回的消息发送到的通道。提供后，底层的 AMQP 模板将配置为将无法传递的消息返回到适配器。如果未配置 `ErrorMessageStrategy`，则消息将根据从 AMQP 收到的数据构建，并具有以下附加标头：`amqp_returnReplyCode`、`amqp_returnReplyText`、`amqp_returnExchange`、`amqp_returnRoutingKey`。当存在 `ErrorMessageStrategy` 时，消息为 `ErrorMessage`，其有效负载为 `ReturnedAmqpMessageException`。另请参阅发布者确认和返回的替代机制。可选。
16	对用于在发送返回或负确认的消息时构建 `ErrorMessage` 实例的 `ErrorMessageStrategy` 实现的引用。
17	对在发送 AMQP 消息时要使用的 `AmqpHeaderMapper` 的引用。默认情况下，只有标准 AMQP 属性（例如 `contentType`）会被复制到 Spring 集成 `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。