我正在尝试从某个目录读取所有文件并对其进行操作。有很多文件,每分钟都有新文件添加到目录中。
当我启动我的应用程序并且目录中有一组文件时。它们按排序顺序处理,但是当新文件被添加到目录时,它们被添加到将要处理的文件排序队列的后面?
有没有解决的办法 ?这就是为什么 Resequencers 存在于 Camel 中的原因吗?http://camel.apache.org/resequencer.html
当前设置:
<camel:endpoint id="store.in" uri="file:${service.in}?readLock=true&recursive=true&moveFailed=${service.error}&sortBy=reverse:file:name" />
<camel:route>
<camel:from uri="ref:store.in" />
<camel:resequence>
<camel:simple>filename</camel:simple>
<camel:to uri="bean:parser?method=parseStream" />
<camel:to uri="log:com.foo.store.parsefile?level=INFO" />
<camel:process ref="storeProcessor" />
</camel:resequence>
</camel:route>