SFTP Persistent Accepter Seulement Une fois le filtre sur la passerelle sftp

Question

J'ai ce code dans lequel je veux incorporer un SftpPersistentAcceptOnceFileListFilter et je ne sais pas comment. Le filtre doit être avant de récupérer les fichiers localement.

@InboundChannelAdapter(value = "sftpMgetInputChannel", 
    poller = @Poller(fixedDelay = "5000")) 
public String filesForMGET(){ 
    return "'/tmp/input/remoteDirectory/*'"; 
} 

@Bean 
public IntegrationFlow sftpMGetFlow() { 
    return IntegrationFlows.from("sftpMgetInputChannel") 
      .handleWithAdapter(h -> h.sftpGateway(this.sftpSessionFactory, 
      Command.MGET, "payload") 
      .options(Option.RECURSIVE) 
      .regexFileNameFilter("((\\d{8})|*\\.txt)") 
      .localDirectoryExpression("'sftp-inbound/'" + "#remoteDirectory")) 
      .handler(messageHandler()) 
      .get(); 
} 

@Bean 
public MessageChannel sftpMgetInboundChannel(){ 
    return new DirectChannel(); 
} 

@Bean 
public MessageHandler messageHandler(){ 
return new MessageHandler() { ... } 
} 

Answer 1

Utiliser un CompositeFileListFilter ou ChainFileListFilter avec un filtre SftpRegexPatternFileListFilter et le SftpPersistentAcceptOnceFileListFilter.

Construire le filtre et utiliser .filter(compositeFilter()).