ポーリングされた受信チャネルアダプター

概要

バージョン 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 がサポートしている場合）。