我有一个 Spring 集成文件轮询实现,它正在轮询特定目录,在此过程中将选择文件并将文件相关的元数据传递到下游系统。在某些情况下,我想从文件轮询目录中再次处理相同的文件,目前该目录不接受。我相信第一次处理该文件时会维护一些状态,但我想处理它,无论如何都允许重复文件处理,即使它已经处理过。需要覆盖哪个过滤器?也尝试过 PreventDuplicates 是 false ,没有运气。尝试使用一些实现 FileListFilter 的自定义过滤器,但它没有从我的 DSL 过滤器中调用。有什么建议或更清洁的方法吗?
尝试自定义实现未成功`
your text
是的。默认情况下,文件不会被反复处理。默认使用
AcceptOnceFileListFilter
。
你需要调查一下
AcceptAllFileListFilter
:
Files.inboundAdapter(directory)
.filter(new AcceptAllFileListFilter<>())