IMO, вам не нужно использовать FileReadingMessageSource
(и внедрять Spring Integration) в базовом сценарии использования.
Вы можете создать ридер, который возвращает File
, процессор, который отображаетFile
к корневому объекту (и разделить на два объекта) и, наконец, FlatFileItemWriter
для генерации CSV-вывода.
РЕДАКТИРОВАТЬ: добавить пример читателя:
@Bean
public ItemReader<File> itemReader() throws IOException {
List<File> files = Files.walk(Paths.get("/path/to/directory"))
.filter(Files::isRegularFile)
.map(Path::toFile)
.collect(Collectors.toList());
return new IteratorItemReader<>(files);
}