Intégration de printemps Java - comment utiliser @InboundChannelAdapter pour vérifier un répertoire pour les fichiers?

Question

Comment puis-je obtenir @InboundChannelAdapter pour travailler avec des fichiers? quelque chose comme ceci:

<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> 

mais en java?

Answer 1

Quelque chose comme ceci:

@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; 
} 

De l'autre attention de rémunération côté, s'il vous plaît, au projet Spring Integration Java DSL, en utilisant que le même peut ressembler à:

@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(); 
    }