出站网关
以下列表显示了 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 交换器名称。如果未提供,消息将被发送到默认的无名称交换器。与 'exchange-name-expression' 互斥。可选。 |
5 | 一个 SpEL 表达式,用于确定应将消息发送到的 AMQP 交换器名称,消息作为根对象。如果未提供,消息将被发送到默认的无名称交换器。与 'exchange-name' 互斥。可选。 |
6 | 注册多个消费者时,此消费者的顺序,从而启用负载均衡和故障转移。可选(默认为 Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE] )。 |
7 | 接收到来自 AMQP 队列的回复并转换后,应将回复发送到的消息通道。可选。 |
8 | 网关在将回复消息发送到 reply-channel 时等待的时间。这仅适用于 reply-channel 可能阻塞的情况,例如具有容量限制且当前已满的 QueueChannel 。默认为无限大。 |
9 | 当为 true 时,如果在 AmqpTemplate 的 replyTimeout 属性指定的时间内未收到回复消息,网关将抛出异常。默认为 true 。 |
10 | 发送消息时使用的 routing-key 。默认情况下,这是一个空 String 。与 'routing-key-expression' 互斥。可选。 |
11 | 一个 SpEL 表达式,用于确定发送消息时使用的 routing-key ,消息作为根对象(例如 'payload.key')。默认情况下,这是一个空 String 。与 'routing-key' 互斥。可选。 |
12 | 消息的默认投递模式:PERSISTENT 或 NON_PERSISTENT 。如果 header-mapper 设置了投递模式,则会被覆盖。如果 Spring Integration 消息头 amqp_deliveryMode 存在,DefaultHeaderMapper 将设置其值。如果未提供此属性且头映射器未设置,则默认值取决于 RabbitTemplate 使用的底层 Spring AMQP MessagePropertiesConverter 。如果未进行任何自定义,默认值为 PERSISTENT 。可选。 |
13 | 自版本 4.2 起。定义关联数据的表达式。提供此属性时,将配置底层 AMQP 模板以接收 publisher confirms。需要专用的 RabbitTemplate 和 CachingConnectionFactory ,其中 publisherConfirms 属性设置为 true 。当收到 publisher confirm 并提供了关联数据时,根据确认类型,它会被写入到 confirm-ack-channel 或 confirm-nack-channel 。确认的 payload 是由该表达式定义的关联数据。消息带有一个头 'amqp_publishConfirm',设置为 true (ack ) 或 false (nack )。对于 nack 确认,Spring Integration 提供了额外的头 amqp_publishConfirmNackCause 。示例:headers['myCorrelationData'] 和 payload 。如果表达式解析为一个 Message<?> 实例(例如 #this ),则在 ack /nack 通道上发出的消息基于该消息,并添加额外的头。以前,无论类型如何,都会创建一个新消息,其 payload 是关联数据。另请参见 Publisher Confirms 和 Returns 的替代机制。可选。 |
14 | 发送正向 (ack ) publisher confirms 的通道。payload 是由 confirm-correlation-expression 定义的关联数据。如果表达式是 #root 或 #this ,则消息基于原始消息构建,并设置 amqp_publishConfirm 头为 true 。另请参见 Publisher Confirms 和 Returns 的替代机制。可选(默认为 nullChannel )。 |
15 | 发送负向 (nack ) publisher confirms 的通道。payload 是由 confirm-correlation-expression 定义的关联数据(如果未配置 ErrorMessageStrategy )。如果表达式是 #root 或 #this ,则消息基于原始消息构建,并设置 amqp_publishConfirm 头为 false 。如果存在 ErrorMessageStrategy ,则消息是一个 ErrorMessage ,其 payload 为 NackedAmqpMessageException 。另请参见 Publisher Confirms 和 Returns 的替代机制。可选(默认为 nullChannel )。 |
16 | 设置此属性后,如果在指定毫秒时间内未收到 publisher confirm,网关将合成一个否定确认 (nack)。待处理的 confirms 每隔此值的 50% 进行检查,因此实际发送 nack 的时间将在此值的 1 到 1.5 倍之间。默认值为 none(不会生成 nacks)。 |
17 | 发送返回消息的通道。提供此属性后,底层 AMQP 模板会被配置为将不可投递的消息返回给适配器。如果未配置 ErrorMessageStrategy ,则消息会根据从 AMQP 接收到的数据构建,并包含以下附加头:amqp_returnReplyCode 、amqp_returnReplyText 、amqp_returnExchange 和 amqp_returnRoutingKey 。如果存在 ErrorMessageStrategy ,则消息是一个 ErrorMessage ,其 payload 为 ReturnedAmqpMessageException 。另请参见 Publisher Confirms 和 Returns 的替代机制。可选。 |
18 | 用于在发送返回或否定确认消息时构建 ErrorMessage 实例的 ErrorMessageStrategy 实现的引用。 |
19 | 当设置为 false 时,端点在应用程序上下文初始化期间尝试连接到代理。如果代理宕机,通过记录错误消息,这可以实现“快速失败”检测不良配置。当设置为 true (默认值)时,连接在发送第一条消息时建立(如果由于其他组件已建立而尚未建立)。 |
return-channel
使用 |
底层 AmqpTemplate 的默认 replyTimeout 是五秒。如果您需要更长的超时,必须在 template 上配置它。 |
请注意,出站适配器和出站网关配置之间的唯一区别是 expectReply
属性的设置。