对于最新的稳定版本,请使用 Spring Integration 6.4.0! |
入站网关
入站网关支持入站通道适配器上的所有属性(除了 'channel' 被 'request-channel' 替换),以及一些其他属性。 以下清单显示了可用的属性:
-
Java DSL
-
Java
-
XML
@Bean // return the upper cased payload
public IntegrationFlow amqpInboundGateway(ConnectionFactory connectionFactory) {
return IntegrationFlow.from(Amqp.inboundGateway(connectionFactory, "foo"))
.transform(String.class, String::toUpperCase)
.get();
}
@Bean
public MessageChannel amqpInputChannel() {
return new DirectChannel();
}
@Bean
public AmqpInboundGateway inbound(SimpleMessageListenerContainer listenerContainer,
@Qualifier("amqpInputChannel") MessageChannel channel) {
AmqpInboundGateway gateway = new AmqpInboundGateway(listenerContainer);
gateway.setRequestChannel(channel);
gateway.setDefaultReplyTo("bar");
return gateway;
}
@Bean
public SimpleMessageListenerContainer container(ConnectionFactory connectionFactory) {
SimpleMessageListenerContainer container =
new SimpleMessageListenerContainer(connectionFactory);
container.setQueueNames("foo");
container.setConcurrentConsumers(2);
// ...
return container;
}
@Bean
@ServiceActivator(inputChannel = "amqpInputChannel")
public MessageHandler handler() {
return new AbstractReplyProducingMessageHandler() {
@Override
protected Object handleRequestMessage(Message<?> requestMessage) {
return "reply to " + requestMessage.getPayload();
}
};
}
<int-amqp:inbound-gateway
id="inboundGateway" (1)
request-channel="myRequestChannel" (2)
header-mapper="" (3)
mapped-request-headers="" (4)
mapped-reply-headers="" (5)
reply-channel="myReplyChannel" (6)
reply-timeout="1000" (7)
amqp-template="" (8)
default-reply-to="" /> (9)
1 | 此适配器的唯一 ID。 自选。 |
2 | 将转换后的消息发送到的消息通道。 必填。 |
3 | 对接收 AMQP 消息时使用的引用。
自选。
默认情况下,只有标准的 AMQP 属性(例如 )被复制到 Spring Integration 或从 Spring Integration 复制。
默认情况下,AMQP 中的任何用户定义的标头都不会复制到 AMQP 消息或从 AMQP 消息复制。
如果提供了 'request-header-names' 或 'reply-header-names',则不允许。AmqpHeaderMapper contentType MessageHeaders MessageProperties DefaultAmqpHeaderMapper |
4 | 要从 AMQP 请求映射到 .
仅当未提供 'header-mapper' 引用时,才能提供此属性。
此列表中的值也可以是与 Headers 名称匹配的简单模式(例如 或 或 )。MessageHeaders "*" "thing1*, thing2" "*thing1" |
5 | 要映射到 AMQP 回复消息的 AMQP 消息属性的名称列表的逗号分隔。
所有标准 Headers(例如 )都映射到 AMQP 消息属性,而用户定义的 Headers 映射到 'headers' 属性。
只有在未提供 'header-mapper' 引用时才能提供此属性。
此列表中的值也可以是要与报头名称匹配的简单模式(例如, or or or )。MessageHeaders contentType "*" "foo*, bar" "*foo" |
6 | 需要回复 Messages 的消息通道。 自选。 |
7 | 设置用于从 reply channel 接收消息的底层。
如果未指定,则此属性默认为 (1 秒)。
仅当容器线程在发送回复之前移交给另一个线程时适用。receiveTimeout o.s.i.core.MessagingTemplate 1000 |
8 | 自定义的 bean 引用(以便更好地控制要发送的回复消息)。
您可以提供 .AmqpTemplate RabbitTemplate |
9 | 当 没有属性时使用。
如果未指定此选项,则提供 no,请求消息中不存在任何属性,并且
an 被抛出,因为无法路由回复。
如果未指定此选项并且提供了 external,则不会引发异常。
您必须指定此选项或配置默认 and 在该模板上,
如果您预见到请求消息中不存在任何属性的情况。replyTo o.s.amqp.core.Address requestMessage replyTo amqp-template replyTo IllegalStateException amqp-template exchange routingKey replyTo |
请参阅 Inbound Channel Adapter 中有关配置属性的说明。listener-container
从版本 5.5 开始,可以使用在内部调用重试操作时使用的策略进行配置。
有关更多信息,请参阅 JavaDocs。AmqpInboundChannelAdapter
org.springframework.amqp.rabbit.retry.MessageRecoverer
RecoveryCallback
setMessageRecoverer()
批量消息
请参阅 Batched Messages (批量消息)。