Я нахожусь в процессе изменения этого стартера для соответствия моим требованиям:
https://github.com/spring-cloud-stream-app-starters/file/blob/master/spring-cloud-starter-stream-source-file/src/main/java/org/springframework/cloud/stream/app/file/source/FileSourceConfiguration.java
Я пытаюсь получить доступ к фактическому файлу, который будучи созданным в папке, из которой запрашивается приложение, я хочу сохранить метаданные о файле (и принять определенные решения на его основе) до его передачи в выходной канал. Например, глядя на тесты, ContentPayloadTests.testSimpleFile () я хочу получить доступ к файлу test.txt до того, как сообщение будет сгенерировано и размещено на канале source.output ().
Любая помощь приветствуется! Спасибо!
Решением было реализовать метод preSend интерфейса ChannelInterceptor.
https://docs.spring.io/spring-integration/archive/1.0.0.M6/reference/html/ch02s05.html