331.5. Samples
在以下示例中,我们将信息从 direct:in
端点路由到 System.out
流:
以下示例演示了如何使用标头类型来确定要使用的流。在示例中,我们使用自己的输出流 MyOutputStream
。
以下示例演示了如何持续读取文件流(类似于 UNIX tail
命令):
from("stream:file?fileName=/server/logs/server.log&scanStream=true&scanStreamDelay=1000") .to("bean:logService?method=parseLogLine");
from("stream:file?fileName=/server/logs/server.log&scanStream=true&scanStreamDelay=1000")
.to("bean:logService?method=parseLogLine");
一个带有 scanStream (pre Camel 2.7)或 scanStream + retry 的 getcha,文件将在每次 scanStreamDelay 迭代被重新打开并扫描。在 NIO2 可用之前,我们无法可靠地检测文件何时被删除/创建。
如果要重新加载文件,如果文件滚动/重写,则您还应打开 fileWatcher
和 retry
选项。
from("stream:file?fileName=/server/logs/server.log&scanStream=true&scanStreamDelay=1000&retry=true&fileWatcher=true") .to("bean:logService?method=parseLogLine");
from("stream:file?fileName=/server/logs/server.log&scanStream=true&scanStreamDelay=1000&retry=true&fileWatcher=true")
.to("bean:logService?method=parseLogLine");