总的来说,我是 spring-camel 和 apache Camel 的新手
我读过 http://camel.apache.org/file.html
我想听文件修改。
因此我写道:
@PostConstruct
public void init() {
from("file:feed.txt")
.log("msg: ${body}")
.process(exchange -> {
System.out.println(exchange.getIn().getBody());
});
}
init
启动时调用方法,但不调用进程回调。
我尝试在启动后向文件中添加新行,但没有任何反应。
我也确信应用程序会看到该文件,因为它在启动时登录:
2017-10-24 15:26:13.421 INFO 10620 --- [ main] o.a.camel.spring.SpringCamelContext : Route: route1 started and consuming from: file://feed.txt
我做错了什么?
正确链接:
http://people.apache.org/~dkulp/camel/file2.html
我创建了目录
feed
而不是文件feed.txt
并将几个文件放在那里。然后我启动应用程序并
Camel
阅读它,Camel
将我的文件移动到.camel
目录中。还尝试动态放置文件。我将文件放入 feed
文件夹并 Camel
成功读取它。