Headerenricher Spring 集成和 java dsl

Question

我正在使用 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
    }

谁能帮帮我？

Answer 1

您可以让您的FileHeaderNamingEnricher 扩展AbstractReplyProducingMesageHandler（将您的代码放入handleRequestMessage()）。

或者，实现GenericHandler<T>（它的handle方法获取payload和headers作为参数，可以返回消息）。

然后使用.handle方法...

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

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