Headerenricher Spring Integration和Java DSL [英] Headerenricher Spring Integration and java dsl

问题描述

我正在使用Spring Integration和java dsl规范来实现我的IntegrationFlow。
我想使用自定义的头文件扩充工具来向头文件添加一些文件名，就像这样：

I'me using Spring Integration and java dsl specifications to implement my IntegrationFlow. I want to use an custom header enricher to add some file names to the header, it will be something like :

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
    }

丰富标题，请问有人可以帮我吗？

Can any one help me with this please ?

推荐答案

您可以将 FileHeaderNamingEnricher 扩展为 AbstractReplyProducingMesageHandler （将您的代码放入 handleRequestMessage（）中）。

You can have your FileHeaderNamingEnricher extend AbstractReplyProducingMesageHandler (put your code in handleRequestMessage()).

或者，实现 GenericHandler< T> （其句柄方法将有效负载和标头作为参数，并可以返回消息。）

Or, implement GenericHandler<T> (its handle method gets the payload and headers as parameters and can return a message).

然后使用 .handle 方法...

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

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

这篇关于Headerenricher Spring Integration和Java DSL的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！