代码之家 › 专栏 › 技术社区 › Makky

使用来自转换器的值充实标头

spring-integration-dsl spring-integration java-8

Makky · 技术社区 · 7 年前

spring integration flow. 它读取文件。该文件可以属于消费者。一旦找到消费者,我想添加该文件 消费者 到页眉,以便稍后我可以使用,例如 错误处理 consumer

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

enrichHeaders 这是由 ConsumerFinderTransformer 在这里

我找不到办法。任何帮助都将被告知

1 回复 | 直到 7 年前

Artem Bilan 7 年前

这是给你的:

    /**
 * 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â)

推荐文章

BÅaÅ¼ej Karwowski · 如何处理JmsChannelFactoryBean错误,是否有可能使用自定义错误通道?

8 年前

m.gavr · 在Spring集成中,如何处理拆分后的消息(即使会出现错误)?

8 年前

Klaus Stadler · 在spring集成应用程序中禁用jackson的时区调整

8 年前

Roman · Spring集成:刷新/重新加载动态注册的IntegrationFlow

8 年前

Nick Tsitlakidis · 如何推迟spring集成中的消息消耗

8 年前

kiran reddy · split&aggregate flow中的Spring集成验证

8 年前

Tom · int http的请求-响应延迟时间:出站网关

8 年前

escos · Spring集成-哪种反序列化器用于只有一个起始字节的无限字节流(作为消息的一部分)

8 年前

user55926 · 如何验证使用Spring SFTP下载的文件的校验和

8 年前

user1516815 · 使用带有spring rest模板的Oauth2(授权码)rest api

8 年前