Настройте сканер каталога на входящем канале с помощью Spring Integration Java DSL в Spring Integration 5

Question

Итак, Spring Integration 5 представила концепцию сканера каталогов для входящих каналов, и я заинтересован в том, чтобы использовать это с моим ftp-каналом.

Однако я не уверен, как настроить его с помощью Java DSL.В docs говорится, что я могу установить сканер на адаптере входящего канала сканера в формате xml.Тем не менее, я использую Spring Integration DSL через IntegrationFlow , и кажется, что я не могу настроить этот сканер каталогов при таком подходе ...

Это правда?Есть ли способ, которым я могу установить сканер каталогов с IntegrationFlow.Я знаю, что могу перейти к более формальному подходу Java Config, но я бы предпочел не делать этого, так как это потребовало бы много работы.

Answer 1

Похоже, мы только что пропустили добавление опции scanner в DSL.

Однако вот вам простой обходной путь:

    FtpInboundFileSynchronizingMessageSource ftpSource =
            Ftp.inboundAdapter(sessionFactory())
                    .regexFilter(".*\\.txt$")
                    .get();
    ftpSource.setScanner(...);
    IntegrationFlow flow = IntegrationFlows.from(ftpSource,

Итак, что вам нужноизвлечь целевой объект из спецификации DSL и напрямую вызвать его установщик.

Не стесняйтесь вносить опцию .scanner() в RemoteFileInboundChannelAdapterSpec обратно в Framework!