Spring Integration - 如何读取 txt 并打印它的文件名？

Question

我的目标是继续读取文件夹并在文件夹中检测到新文件名时打印文件名。

我实际上会添加更多功能，但这是我尝试完成的第一步。

谢谢。

@Bean
public IntegrationFlow fileReadingFlow() {
    return IntegrationFlows
        .from(s -> s.file(new File('/tmp/test'))
            .patternFilter("*.txt"),
                e -> e.poller(Pollers.fixedDelay(1000)))
                    .transform(Transformers.fileToString())
                    ##### What do I need to do here to print the file name?
                    .get();
}

Answer 1

.handle(m -> System.out.println(m.getHeaders().get(FileHeaders.FILENAME)))

FileToStringTransformer 在转换期间填充这样的标头：

T result = this.transformFile(file);
        Message<?> transformedMessage = getMessageBuilderFactory().withPayload(result)
                .copyHeaders(message.getHeaders())
                .setHeaderIfAbsent(FileHeaders.ORIGINAL_FILE, file)
                .setHeaderIfAbsent(FileHeaders.FILENAME, file.getName())
                .build();