Spring Java integration - how to use @InboundChannelAdapter to check directory for files?

Question

How can I get @InboundChannelAdapter to work with files? something like that:

<int-file:inbound-channel-adapter id="executionMessageFileInputChannel" directory="file:${fpml.messages.input}" prevent-duplicates="false" filename-pattern="*.xml"> <int:poller fixed-delay="20000" max-messages-per-poll="1" /> </int-file:inbound-channel-adapter> 

but in java?

Answer 1

Something like that:

 @Bean @InboundChannelAdapter(value = "executionMessageFileInputChannel", poller = @Poller(fixedDelay = "20000", maxMessagesPerPoll = "1")) public MessageSource<File> fileMessageSource(@Value("${fpml.messages.input}") File directory) { FileReadingMessageSource fileReadingMessageSource = new FileReadingMessageSource(); fileReadingMessageSource.setDirectory(directory); fileReadingMessageSource.setFilter(new SimplePatternFileListFilter("*.xml")); return fileReadingMessageSource; } 

On the other hand, pay attention to the Spring Integration Java DSL project, which might look like this:

  @Bean public IntegrationFlow fileReadingFlow(@Value("${fpml.messages.input}") File directory) { return IntegrationFlows .from(s -> s.file(directory).patternFilter("*.xml"), e -> e.poller(Pollers.fixedDelay(20000))) ..................... .get(); }