SpringIntegration轮询器复制文件

我已经设置了任务执行器的文件轮询器

ExecutorService executorService = Executors.newFixedThreadPool(10);

            LOG.info("Setting up the poller for directory {} ", finalDirectory);
            StandardIntegrationFlow standardIntegrationFlow = IntegrationFlows.from(new CustomFileReadingSource(finalDirectory),
                    c -> c.poller(Pollers.fixedDelay(5, TimeUnit.SECONDS, 5)
                            .taskExecutor(executorService)
                            .maxMessagesPerPoll(10)
                            .advice(new LoggerSourceAdvisor(finalDirectory))
                    ))


                    //move file to processing first processing                    
                    .transform(new FileMoveTransformer("C:/processing", true))
                    .channel("fileRouter")
                    .get();

我使用的是基于AcceptOnceFilter的lastUpdated。

它的所有工作良好的问题,我有一个目录,我投票的文件来自外部系统。文件仍在被复制,应用程序提取并处理部分数据。

如何在处理之前确保文件已完全写入。

我无法更改外部系统,因为他们只是将文件复制到文件夹中。他们不会改变他们的制度。