輪詢入站通道介面卡

概述

版本 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 支援）。