有没有办法通过检测ACK文件来处理文件



我有一个应用程序,文件定期出现在一个文件夹中。 总是有两个文件出现,一个名为ACK+文件名并且为空,另一个只是文件名(这个是数据文件(。

我从一些人那里听说,Camel有一种方法可以通过检测ACK来处理我的文件。

我目前正在做的是检测ACK文件,然后触发一个进程,该进程将获取数据文件并对其进行处理。但是有了这个,我无法对我的代码进行工作单元测试。

但是,如果可能的话,我宁愿有一个检测我的 ACK 但使用数据文件触发该过程的路由。

这可能吗?

这是我的实际路线:

@Component
public class MyRoute extends RouteBuilder {
public static final String ROUTE_NAME = "myRoute";
private final Processor myProcessor;
@Autowired
public MyRoute(@Qualifier("my.processor") Processor myProcessor) {
this.myProcessor= myProcessor;
}
@Override
public void configure() throws Exception {
from("file://{{data.input.dir}}?moveFailed=errors&delete=true&include=ACK.*").routeId(ROUTE_NAME)
.choice()
.when(header("CamelFileName").startsWith("ACK"))
.process(myProcessor)
.end();
}
}

编辑:使用doneFileName选项找到解决方案

正如您自己发现的那样,Camel可以使用doneFileName选项自动处理此问题。

您根本不需要处理 ACK 文件。

但结果是:如果缺少ACK文件,则不会处理数据文件,因为Camel将没有done文件的数据文件视为仍在传输/写入过程中。

最新更新