Polled Inbound Channel Adapter

Overview

5.0.1 版本引入了轮询通道适配器,让您能够按需获取单独的消息——例如,使用 MessageSourcePollingTemplate 或轮询器。有关更多信息,请参阅 Deferred Acknowledgment Pollable Message Source

目前不支持 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.

Batched Messages

参见 Batched Messages

对于轮询适配器,没有侦听器容器,批量消息始终被解除批处理(如果 BatchingStrategy 支持这样做)。