Headerenricher Spring Integration and 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
    }

可以有人帮我一下吗？

- wadi3

Answer 1

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

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

然后使用.handle方法...

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

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

- Gary Russell

---

我该如何在我的FileHeaderNamingEnricher中访问有效载荷并设置标头？ - wadi3

AbstractReplyProducingMessageHandler.handleRequestMessage(Message<?> message) - handleRequestMessage 方法接收消息并返回一个对象（也可以是 Message<?>）。因此，代码与您上面的代码完全相同。 - Gary Russell

谢谢，这解决了我的问题。我发现我也可以实现GenericHandler。 - wadi3

是的，已将其添加到答案中。 - Gary Russell

先生，但是我们不能使用 .enrichHeaders() API 调用将一个键（字符串）和 List<String> 作为值放入标头中吗？ - Guru

不要在旧答案上问新问题，尤其是那些已经四年历史的问题。这个问题明确涉及到自定义头部增强器的连线，如果你仍然有问题，请提出一个新的问题。 - Gary Russell