SFTP持久性接受只在sftp网关过滤一次

Question

我有这个代码中我想合并一个SftpPersistentAcceptOnceFileListFilter，我不知道如何。过滤器应在本地检索文件之前进行。

@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

使用CompositeFileListFilter或ChainFileListFilter与SftpRegexPatternFileListFilter过滤器和SftpPersistentAcceptOnceFileListFilter。

构建过滤器并使用.filter(compositeFilter())。