@Test public void should_ignore_non_ser_files() throws Exception { File file = createImportFile(".bar"); task.importPublicationFiles(); assertThat(file.exists(), is(true)); verifyNoMoreInteractions(importer); }
@Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") public void importPublicationFiles() { new NamedThreadTemplate().doInNamedThread("FileImportTask", this::processQueue); }
FileImportTask { @Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") public void importPublicationFiles() { new NamedThreadTemplate().doInNamedThread("FileImportTask", this::processQueue); } }
FileImportTask { @Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") public void importPublicationFiles() { new NamedThreadTemplate().doInNamedThread("FileImportTask", this::processQueue); }  }
FileImportTask { @Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") public void importPublicationFiles() { new NamedThreadTemplate().doInNamedThread("FileImportTask", this::processQueue); }  @PostConstruct void postConstruct(); @Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") void importPublicationFiles(); void doProcessFile(File file); }
FileImportTask { @Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") public void importPublicationFiles() { new NamedThreadTemplate().doInNamedThread("FileImportTask", this::processQueue); }  @PostConstruct void postConstruct(); @Scheduled( initialDelayString = "${codekvast.dashboard.fileImportInitialDelaySeconds:5}000", fixedRateString = "${codekvast.dashboard.fileImportIntervalSeconds}000") void importPublicationFiles(); void doProcessFile(File file);  }