Headerenricher Spring集成与java dsl

Question

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扩展AbstractReplyProductingMesageHandler（将您的代码放入HandleRequestMessage())。

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

然后使用.handle方法...

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

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