出站通道适配器

以下示例展示了 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`。与 'routing-key' 互斥。可选。
9	消息的默认传递模式：`PERSISTENT` 或 `NON_PERSISTENT`。如果 `header-mapper` 设置了传递模式，则会被覆盖。如果存在 Spring Integration 消息头 `amqp_deliveryMode`，则 `DefaultHeaderMapper` 会设置该值。如果未提供此属性且头映射器未设置它，则默认值取决于 `RabbitTemplate` 使用的底层 Spring AMQP `MessagePropertiesConverter`。如果根本没有自定义它，则默认值为 `PERSISTENT`。可选。
10	定义相关数据的表达式。提供此表达式时，将配置底层 AMQP 模板以接收发布者确认。需要一个专用的 `RabbitTemplate` 和一个 `CachingConnectionFactory`，其 `publisherConfirms` 属性设置为 `true`。当收到发布者确认并提供相关数据时，它将写入 `confirm-ack-channel` 或 `confirm-nack-channel`，具体取决于确认类型。确认的有效负载是相关数据，由此表达式定义。消息具有设置为 `true` (`ack`) 或 `false` (`nack`) 的 'amqp_publishConfirm' 标头。示例：`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	对 `AmqpHeaderMapper` 的引用，用于发送 AMQP 消息。默认情况下，只有标准 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需要一个RabbitTemplate，其mandatory属性设置为true，以及一个CachingConnectionFactory，其publisherReturns属性设置为true。当使用多个带有返回的出站端点时，每个端点都需要一个单独的RabbitTemplate。