headerenricher Spring 集成和 java dsl

我使用 Spring Integration 和 java dsl 规范来实现我的 IntegrationFlow。 我想使用自定义标头丰富器将一些文件名添加到标头，它将类似于：

public class FileHeaderNamingEnricher {
    public Message<File> enrichHeader(Message<File> fileMessage) {
            // getting some details fom the database ...
            return messageBuilder
                    .setHeader("filename", "somestuff")
                    .build();
        }  
}

我的集成流程将如下所示：

public IntegrationFlow myflow() {
        return IntegrationFlows.from("input")
                                .enrich // here I want to enrich the header using my class
    }

有人可以帮我解决这个问题吗？

你可以拥有你的FileHeaderNamingEnricher extend AbstractReplyProducingMesageHandler（将你的代码放入handleRequestMessage()).

或者，实施GenericHandler<T> (its handle方法获取有效负载和标头作为参数，并且可以返回消息）。

然后使用.handle方法...

 ...
 .handle(myEnricher())
 ...

 @Bean
 public void MessageHandler myEnricher() {
    return new FileHeaderNamingEnricher();
 }