我正在使用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
}
可以有人帮我一下吗?
AbstractReplyProducingMessageHandler.handleRequestMessage(Message<?> message)
-handleRequestMessage
方法接收消息并返回一个对象(也可以是Message<?>
)。因此,代码与您上面的代码完全相同。 - Gary Russell