使用Java DSL从文件轮询-添加Files.inboundAdapter时发生编译错误

Question

我正在使用Spring Integration Java DSL v。1.2.2并遵循一些示例，我尝试编写代码以轮询文件夹

    return IntegrationFlows
            .from(Files.inboundAdapter(new File("/tmp/foo")))
            .handle((p, h) -> fileProcessor.process(p))
            .get();

该代码无法编译，因为

"Cannot resolve method 'from(org.springframework.integration.dsl.
   file.FileInboundChannelAdapterSpec)'"

如何解决此问题以及如何添加固定间隔的轮询？

Answer 1

尚不清楚您的IDE中发生了什么，但是我们在测试用例中有以下示例：

@Bean
public IntegrationFlow fileToFile() {
    return IntegrationFlows.from(Files.inboundAdapter(new File("/tmp/in"))
                    .autoCreateDirectory(true)
                    .patternFilter("*.txt"),
            e -> e.poller(Pollers.fixedDelay(5000)))
            .transform(Transformers.fileToString())
            .transform("payload.replaceAll('\r\n', '\n')")
            .handle(Files.outboundAdapter("'/tmp/out'")
                    .autoCreateDirectory(true))
            .get();
}

这fixedDelay()是您有关的第二个问题的答案fixed-interval。

https://github.com/spring-projects/spring-integration-java-
dsl/blob/master/src/test/java/org/springframework/integration/dsl/samples/file2file1/FileChangeLineSeparator.java