Spring Cloud Dataflow 文件启动器修改

Question

我正在修改这个启动器以满足我的要求：

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() 我希望能够在生成消息并将其发布到 source.output() 通道之前访问 test.txt 文件。

感谢任何帮助！谢谢！

Answer 1

解决方案是实现 ChannelInterceptor 接口的 preSend 方法..

https://docs.spring.io/spring-integration/archive/1.0.0.M6/reference/html/ch02s05.html