出站通道适配器

以下示例展示了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 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`时，调用线程将阻塞，等待发布者确认。这需要配置为`confirms`的`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	对`ErrorMessageStrategy`实现的引用，用于在发送返回或否定确认的消息时构建`ErrorMessage`实例。
17	对`AmqpHeaderMapper`的引用，用于发送AMQP消息。默认情况下，只有标准的AMQP属性（例如`contentType`）被复制到Spring Integration `MessageHeaders`。任何用户定义的头都不会被默认的`DefaultAmqpHeaderMapper`复制到消息中。如果提供了`request-header-names`，则不允许。可选。
18	逗号分隔的AMQP头名称列表，用于从`MessageHeaders`映射到AMQP消息。如果提供了“header-mapper”引用，则不允许。此列表中的值也可以是用于匹配头名称的简单模式（例如`""`或`"thing1, thing2"`或`"*thing1"`）。
19	设置为`false`时，端点会在应用程序上下文初始化期间尝试连接到代理。这允许“快速失败”检测错误配置，但如果代理关闭也会导致初始化失败。当为`true`（默认值）时，连接在发送第一条消息时建立（如果由于其他组件建立而尚未存在）。
20	设置为`true`时，类型为`Iterable<Message<?>>`的负载将作为离散消息在同一通道上，在单个`RabbitTemplate`调用的范围内发送。需要`RabbitTemplate`。当`wait-for-confirms`为true时，消息发送后会调用`RabbitTemplate.waitForConfirmsOrDie()`。对于事务模板，发送将在新的事务中执行，或者在已启动的事务中执行（如果存在）。

返回通道

使用return-channel需要一个RabbitTemplate，其mandatory属性设置为true，以及一个CachingConnectionFactory，其publisherReturns属性设置为true。当多个出站端点使用返回时，每个端点都需要一个单独的RabbitTemplate。