spring-integration - Spring集成DSL文件轮询入站通道适配器示例

Question

在任何地方都找不到使用 spring 集成 DSL only xml 的示例。任何指针表示赞赏，还需要轮询器在文件创建和修改时触发

Answer 1

这个怎么样：

@Bean
public IntegrationFlow fileReadingFlow() {
    return IntegrationFlows
            .from(s -> s.file(tmpDir.getRoot()).patternFilter("*.sitest"),
                    e -> e.poller(Pollers.fixedDelay(100)))
            .transform(Transformers.fileToString())
            .channel(MessageChannels.queue("fileReadingResultChannel"))
            .get();
}

? .from()工厂方法在这里接受一个工厂MessageSources，您从中使用.file()工厂方法等等。

更多信息在项目测试中：https ://github.com/spring-projects/spring-integration-java-dsl/tree/master/src/test/java/org/springframework/integration/dsl/test