java Spring集成LastModifiedFileListFilter不工作
我正试图从一个目录中读取一些文件,在检测到文件和处理文件之间有一个延迟。 我有一个生成器模式:
/**
* The build function that will create a CompositeFileListFilter with the given filters
*
* @return {@link CompositeFileListFilter} that contains all the filters added
*/
public CompositeFileListFilter<File> build() {
CompositeFileListFilter<File> compositeFileListFilter = new CompositeFileListFilter<>();
boolean existsFilters = false;
// Add the prevent duplicates filter
if (this.preventDuplicates) {
compositeFileListFilter.addFilter(new AcceptOnceFileListFilter<File>());
existsFilters = true;
} else {
compositeFileListFilter.addFilter(new AcceptAllFileListFilter<File>());
existsFilters = true;
}
// Add the ignore hidden filter
if (this.ignoreHidden) {
compositeFileListFilter.addFilter(new IgnoreHiddenFileListFilter());
existsFilters = true;
} // Add the pattern file name filter
if (this.patternFilter != null) {
compositeFileListFilter.addFilter(new SimplePatternFileListFilter(patternFilter));
existsFilters = true;
}
// Add the process file after a period of time filter
if (this.lastModifiedFileListFilterAge > 0) {
LastModifiedFileListFilter filter = new LastModifiedFileListFilter();
filter.setAge(lastModifiedFileListFilterAge);
compositeFileListFilter.addFilter(filter);
existsFilters = true;
}
// Check if compositeFileListFilter contains any filter
if (!existsFilters) {
throw new IllegalStateException("At least one filter should be provided!");
}
return compositeFileListFilter;
}
我正在创建这样的过滤器
CompositeFileListFilter<File> filters = new IntegrationFlowFileFilterBuilder()
.ignoreHidden(true)
.preventDuplicates(false)
.patternFilter(returnInformationInputFolderSetup.getPatternFolder())
.lastModifiedFileListFilterAge(120)
.build();
问题是所有其他过滤器都在工作,只有LastModifiedFileList过滤器不工作。。我正在读一个文件,不到一秒钟就被处理了
有人知道为什么这个过滤器不工作吗
共 (0) 个答案