java - 在 Spring Integration 中的消息 header 中设置文件名

标签 java spring spring-integration

我想在消息的标题中设置文件名。所以我放置了标题丰富器:

<int:header-enricher input-channel="singleFile" output-channel="fileNameAddedToHeader">
         <int:header name="file-name" ref="fileNameHeaderEnricher" method="enrichHeader"/>
</int:header-enricher>

丰富方法是:

public Message<File> enrichHeader(Message<File> fileMessage) {
    File file = (File) fileMessage.getPayload();
    Message<File> messageOut =
        MessageBuilder.withPayload(fileMessage.getPayload()).copyHeadersIfAbsent(fileMessage.getHeaders())
            .setHeaderIfAbsent("file-name", file.getName()).build();
    return messageOut;
  }

但是 header 似乎没有正确添加。

.11:32:33.248 [task-scheduler-1] DEBUG o.s.i.channel.DirectChannel - postSend (sent=true) on channel 'fileNameAddedToHeader', message: GenericMessage [payload=/home/cost1.txt, headers={timestamp=1418363253171, id=d119e90e-938c-89c3-803e-e980da3de2db, correlationId=d2d5bf51-0647-12db-916d-98884943c08b, file-name=GenericMessage [payload=/home/cost1.txt, headers={timestamp=1418363253170, id=2374031d-4cc8-43bc-f15a-8061c28bec51, correlationId=d2d5bf51-0647-12db-916d-98884943c08b, file-name=costcenter1.txt, sequenceSize=1, sequenceNumber=1}], sequenceSize=1, sequenceNumber=1}] 

似乎file-name包含 header 部分而不是文件名。

file-name=GenericMessage [payload=/home/cost1.txt, headers={timestamp=1418363253170, id=2374031d-4cc8-43bc-f15a-8061c28bec51, correlationId=d2d5bf51-0647-12db-916d-98884943c08b, file-name=costcenter1.txt, sequenceSize=1, sequenceNumber=1}]

我期待 header 中出现file-name=cost1.txt。我在设置标题时做错了什么?是否可以使用 SpEL 将文件名添加到 header 来完成此任务?

最佳答案

是的,这样做是错误的。

参见:

<int:header name="file-name" ref="fileNameHeaderEnricher" method="enrichHeader"/>

假设该方法的结果将填充到 file-name header 。

自从您的 enrichHeader返回 Message对象,我们最终确实看到了这一点。

SpEL 变体看起来更适合您的情况:

<int:header name="file-name" expression="payload.name"/>

请注意,如果您要将其用于下游 <int-file:outbound-channel-adapter> header 必须是 file_name -FileHeaders .

关于java - 在 Spring Integration 中的消息 header 中设置文件名,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27437722/

相关文章:

java - RMI - JRMP 与 IIOP

java - 如何获取TimeZone类中的具体时间

java - hibernate : How to get last n rows in spring boot JpaRepository?

java - 防止发送者 channel 的执行,直到从分离器生成的执行器 channel 完成 Spring Integration 中的处理

java - 自动更新 Swing 应用程序 - Install4J

java - 从 Java 使用 Solrj 连接到 Solr 时出错

java - Spring异步线程 hibernate

Java JPA 过滤器

spring-integration - spring 集成轮询器与调度器

java - com.jcraft.jsch.JSchException : verify: false 错误