以下清单显示了 AMQP 出站网关的可能属性：

  • Java DSL

  • Java

  • XML

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

使用 a 需要 a 的属性设置为 和 a 的属性设置为 。 使用多个返回的出站终结点时，每个终结点都需要一个单独的终结点。return-channelRabbitTemplatemandatorytrueCachingConnectionFactorypublisherReturnstrueRabbitTemplate
返回通道

使用 a 需要 a 的属性设置为 和 a 的属性设置为 。 使用多个返回的出站终结点时，每个终结点都需要一个单独的终结点。return-channelRabbitTemplatemandatorytrueCachingConnectionFactorypublisherReturnstrueRabbitTemplate
基础的默认值为 5 秒。 如果需要更长的超时时间，则必须在 上配置它。AmqpTemplatereplyTimeouttemplate
基础的默认值为 5 秒。 如果需要更长的超时时间，则必须在 上配置它。AmqpTemplatereplyTimeouttemplate

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