轮询入站通道适配器
概述
版本 5.0.1 引入了轮询通道适配器,允许你按需获取单个消息——例如,使用 MessageSourcePollingTemplate
或轮询器。更多信息请参见延迟确认可轮询消息源。
目前它不支持 XML 配置。
以下示例展示了如何配置 AmqpMessageSource
-
Java DSL
-
Java
@Bean
public IntegrationFlow flow() {
return IntegrationFlow.from(Amqp.inboundPolledAdapter(connectionFactory(), DSL_QUEUE),
e -> e.poller(Pollers.fixedDelay(1_000)).autoStartup(false))
.handle(p -> {
...
})
.get();
}
@Bean
public AmqpMessageSource source(ConnectionFactory connectionFactory) {
return new AmqpMessageSource(connectionFactory, "someQueue");
}
有关配置属性,请参见Javadoc。
XML
This adapter currently does not have XML configuration support.
批量消息
参见批量消息。
对于轮询适配器,没有监听器容器,批量消息总是会被分批处理(如果 BatchingStrategy
支持)。