使用Transformer中的值丰富Header

Question

我有一个spring integration flow.，它读取文件。该文件可以属于使用者。一旦我找到消费者，我就想将consumer添加到标题中，以便稍后我可以使用。例如，在错误处理中，我可以检查我是否在标题中看到了consumer。

IntegrationsFlows.from(directorySource)
.transform(new ConsumerFinderTransformer()
.enrichHeaders(h -> h.header("CONSUMER" ,payload)

如何获取ConsumerFinderTransformer返回的enrichHeaders中的有效载荷。

我找不到路。将提供任何帮助

Answer 1

这个就在那里：

/**
* Add a single header specification where the value is a String representation of a
* SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
* unless {@link #defaultOverwrite(boolean)} is true.
* @param name the header name.
* @param expression the expression.
* @return the header enricher spec.
*/
public HeaderEnricherSpec headerExpression(String name, String expression) {

所以，你的代码应该是这样的：

.enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)