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方法获取有效负载和标题作为参数并可以返回消息）。

然后使用.handle方法...

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

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