2

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

4

1 回答 1

2

这个怎么样:

@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

于 2015-07-08T16:05:57.493 回答