spring - SFTP Persistent Accept Only Once 在 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

使用CompositeFileListFilterorChainFileListFilter与SftpRegexPatternFileListFilter过滤器和SftpPersistentAcceptOnceFileListFilter.

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