Headerenricher Spring Integration и 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

Вы можете продлить FileHeaderNamingEnricherAbstractReplyProducingMesageHandler (введите код в handleRequestMessage()).

Или, реализовать GenericHandler<T> (его метод handle получает полезную нагрузку и заголовки в качестве параметров и может возвращать сообщение).

Затем используйте метод .handle ...

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

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