java - Headerenricher Spring Integration 和 java dsl

Question

我正在使用 Spring Integration 和 java dsl 规范来实现我的 IntegrationFlow。我想使用自定义 header 丰富器向 header 添加一些文件名，它类似于:

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
    }

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

Answer 1

您可以拥有您的 FileHeaderNamingEnricher扩展AbstractReplyProducingMesageHandler (将您的代码放在 handleRequestMessage() 中)。

或者，执行 GenericHandler<T> (它的 handle 方法获取有效载荷和 header 作为参数并可以返回消息)。

然后使用 .handle方法...

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

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