我是 Apache Camel 框架的新手。我必须在 Spring Boot 和 Camel 中开发一个应用程序,它反复轮询给定的目录(即使在目录经过任何修改之后,轮询器也应该继续轮询另一个预定的时间间隔等等。我在骆驼中发现了类似下面的代码。
公共类 FilePoller 扩展 RouteBuilder {
@Override
public void configure() {
from("file:H:\\InputFolder?delay=1000&noop=true")
.process(new Processor() {
public void process(Exchange msg) {
File file = msg.getIn().getBody(File.class);
//LOG.info("Processing file: " + file);
System.out.println("Polling file:"+file);
}
});
}
}
上面的代码只等待1秒,然后不轮询目录就执行后面的代码。
任何人都可以帮助我开发一个 Spring Boot-Camel 应用程序,该应用程序在每个给定的时间间隔重复轮询目录或文件。提前致谢