輪詢式輸入通道配接器

概觀

版本 5.0.1 引入了輪詢式通道配接器，讓您可以根據需求擷取個別訊息 — 例如，使用 MessageSourcePollingTemplate 或 poller。請參閱延遲確認輪詢式訊息來源以取得更多資訊。

目前不支援 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 支援這樣做）。