目前,我正在使用 FileReadingMessageSource 使用 Spring Integration 从特定目录读取文件。
@Bean
public MessageSource<File> fileReadingMessageSource() {
FileReadingMessageSource source = new FileReadingMessageSource();
source.setDirectory(new File(/temp));
source.setFilter(new SimplePatternFileListFilter("*.csv"));
source.setUseWatchService(true);
source.setWatchEvents(WatchEventType.CREATE);
return source;
}
问题,我面临的是上面的配置能够从临时文件夹以及临时文件夹中的其他文件夹中读取文件。例如 - 如果我在 temp/csvfolder 之类的临时文件夹中创建一个文件夹,并将 csv 文件放在 csvfolder 中,它仍然能够轮询文件。
我们可以将其限制为仅特定文件夹吗?