java - 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

我正在尝试访问在应用程序轮询的文件夹中创建的实际文件，并且我想在将文件传递到输出 channel 之前保留有关该文件的元数据(并根据它做出某些决定) 。例如。查看测试，ContentPayloadTests.testSimpleFile() 我希望能够在生成消息并将其发布到 source.output() channel 上之前访问 test.txt 文件。

感谢任何帮助!谢谢!

Answer 1

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

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