public FileInboundChannelAdapterSpec rtwTifFileSharePoller() {
CompositeFileListFilter<File> allFilters = new CompositeFileListFilter<>();
allFilters.addFilter(new SimplePatternFileListFilter("*.tif"));
allFilters.addFilter(new LastModifiedFileListFilter(120));
return Files
.inboundAdapter(new File(rtwSharedPath))
.filter(allFilters)
.preventDuplicates(true);
}
Контрольный пример:
@RunWith(SpringRunner.class)
@SpringBootTest
public class RTWFlowsTest {
RTWFlows rtwFlows = new RTWFlows();
@Test
public void rtwTifFileSharePoller() {
System.out.println("executing test");
FileReadingMessageSource getFile = rtwFlows.rtwTifFileSharePoller().get();
Message<File> msg = null;
while( (msg = getFile.receive()) != null)
msg.getHeaders().forEach((key, value) -> System.out.println(key + ": " + value));
}
}
Я отредактировал tif-файл и сразу же запустил контрольный пример, и это тоже было указано в файлах.Не уверен, почему недавно отредактированные файлы (в течение 2 минут), также были перечислены.