我有两个骆驼应用程序,它们的职责是从同一目录中读取文件,处理它们并将它们发送给数据库使用者。为此,我的端点是这样的:
file:/data/air?preMove=thread&readLock=fileLock &idempotent=true&idempotentRepository=#fileStore&include=AIROUTPUTCDR_(.*).AIR.gz&move=/data/air/success&moveFailed=error
如您所见,应用程序根据过滤器从 polldir 轮询文件,将它们移动到线程目录下以读取,读取文件并移动到成功文件夹。
但是在这个流程中,如果我杀死一个应用程序并重新启动它,正在处理的文件将不会被处理,因为它们位于线程文件夹下。
我的问题是,有没有办法恢复读取刚刚中断的文件?
谢谢