找不到文件时的 Spring 集成流日志记录

Question

我已经有一个工作的IntegrationFlow

IntegrationFlows.from(Sftp.inboundAdapter(inboundSftp)
                .localDirectory(this.getlocalDirectory(config.getId()))
                .deleteRemoteFiles(true)
                .autoCreateLocalDirectory(true)
                .filter(new CompositeFileListFilter().addFilter(new LastModifiedLsEntryFileListFilter(config.getRegexFilter())))
                .remoteDirectory(config.getInboundDirectory())
                , e -> e.poller(Pollers.cron(config.getCron())
                        .errorChannel(MessageHeaders.ERROR_CHANNEL).errorHandler((ex) -> {
               }))).publishSubscribeChannel(s -> s
                .subscribe(f -> {
                    ............
                })
                .subscribe(f -> {
                    .......

                })
                .subscribe(f -> f
                        .......
                ))
                .get();

当源目录上不存在文件时，我正在尝试记录。我尝试使用 LastModifiedLsEntryFileListFilter，但只有在服务器上找到文件时才会触发它。

Answer 1

虽然Spring Integration Flow API does not response when empty remote directory的问题来自另一个用户，但看起来你们都在谈论同一个项目和同一个问题。

我无法结束你的问题，因为那里还没有对我的答案进行投票，所以我也只是在这里复制/粘贴我的答案。

Sftp.inboundAdapter(inboundSftp) 是一个基于轮询器配置的计划任务的SourcePollingChannelAdapter。如果没有来自源的数据来构建消息，它实际上不会对outputChannel 产生任何影响。但关键是触发器上的任务仍在执行，我们有一些钩子来捕捉那个阶段。

为此，我们为其afterReceive() 实现提供了一个AbstractMessageSourceAdvice 组件。这是您可以执行“空远程目录”逻辑的地方。这样的Advice 必须注入poller(Pollers...advice())。

在文档中查看更多信息：https://docs.spring.io/spring-integration/docs/5.3.0.M4/reference/html/core.html#conditional-pollers