のJava DSLを使用して、ファイルからのポーリング - Files.inboundAdapter

Question

を追加するとき、私は春の統合の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についてのあなたの2番目の質問への答えです。

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