从文件名表达式调用Apache Camel Spring xml-bean方法

Question

我有以下处理文件（输入）的Apache Camel Spring XML配置。我尝试在复制文件之前重命名它（移动选项）。我希望文件名包含一个字符串，这是返回字符串（getHash）的bean的方法调用的结果。

Apache Camel版本

<dependency>
    <groupId>org.apache.camel</groupId>
    <version>3.0.0</version>
    <type>pom</type>
</dependency>

<?xml version="1.0" encoding="UTF-8"?>
<!-- Configures the Camel Context-->
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
<camelContext id="camelContext-89c763e9" xmlns="http://camel.apache.org/schema/spring">

    <route id="FileConsumption" shutdownRoute="Defer">
        <from id="_from2" uri="file:/home/spool_in/?move=.done&amp;moveFailed=.bad&amp;fileName={bean:videoProcessor.getHash}.{file:name.ext}"/>
        <bean
            beanType="org.mediaprocessor.VideoProcessor" id="_videoProcessor" ref="videoProcessor"/>
    </route>
</camelContext>

<bean id="videoProcessor" class="org.mediaprocessor.VideoProcessor" />
</beans>

<from id="_from2" uri="file:/home/matthieu/spool_in/?move=.done&amp;moveFailed=.bad&amp;fileName=${bean:videoProcessor.getHash}.{file:name.ext}"/>

@Bean
public static String getHash(File file) throws NoSuchAlgorithmException, IOException {
    //Use MD5 algorithm
    MessageDigest md5Digest = MessageDigest.getInstance("MD5");

    //Get the checksum
    String checksum = getFileChecksum(md5Digest, file);
    return checksum;
}

Caused by: org.apache.camel.FailedToCreateRouteException: Failed to create route FileConsumption at: >>> Bean[] <<< in route: Route(FileConsumption)[From[file:/home/spool_in/?mo... because of bean, ref or beanType must be provided
...
Caused by: java.lang.IllegalArgumentException: bean, ref or beanType must be provided
    at org.apache.camel.component.bean.DefaultBeanProcessorFactory.createBeanProcessor(DefaultBeanProcessorFactory.java:67)
    at org.apache.camel.reifier.BeanReifier.createProcessor(BeanReifier.java:47)
    at org.apache.camel.reifier.ProcessorReifier.makeProcessorImpl(ProcessorReifier.java:571)
    at org.apache.camel.reifier.ProcessorReifier.makeProcessor(ProcessorReifier.java:537)
    at org.apache.camel.reifier.ProcessorReifier.addRoutes(ProcessorReifier.java:250)
    at org.apache.camel.reifier.RouteReifier.doCreateRoute(RouteReifier.java:384)
    ... 37 more

最后，我们还可以使用bean表达式调用POJO类，该类生成一些要使用的字符串输出（或可转换为字符串）：

filename=“uniquefile-${bean:MyGuidGenerator.GenerateID}.txt”

https://camel.apache.org/manual/latest/file-language.html

对我遗漏了什么有什么想法吗？谢了！

更新：在“${bean:videoprocessor.gethash}”中添加了“$”符号（错别字）

Answer 1

我不熟悉Camel XML，因为我发现Camel DSL更容易阅读和使用。但是，在来自camel的文档中，您提供了${bean:myguidgenerator.generateid}，而您在路由中没有使用“$”符号:filename={bean:videoprocessor.gethash}

您还需要在文件扩展名中添加一个“$”登录。${file:name.ext}

我还复制了您的项目，在做了这些“$”更改后，应用程序在我这边启动。然而，我相信您的实现有更多的问题，即使您启动了它，它也不会达到您期望的效果。

以下是我认为你的问题：

1. 在filename中使用该beangethash将设置act作为您要使用的文件名的筛选器。从您所说的来看，这不是您想要的。
2. 如果我的理解是正确的，您希望从spool_in文件夹中提取一个视频文件，用视频处理器处理它，一旦处理完毕，将它移到.done文件夹中，同时更改名称。为此，您需要在移动选项下移动文件表达式，如下所示:

uri=“file://home/matthieu/spool_in/？move=.done/${bean:videoprocessor.gethash}.${file:name.ext}

@Component
@Slf4j
public class VideoProcessor {
    public void process(Exchange exchange) {
        log.info("Processing {} video ", ((GenericFile) exchange.getIn().getBody()).getFileName());
    }

    public String getHash(File file) {
        return FilenameUtils.removeExtension(file.getName()) + "_copy";
    }
}

2020-01-03 11:19:50.444  INFO 27988 --- [/temp/spool_in/] c.v.t.g.webservice.camel.VideoProcessor  : Processing Video_1.mpg video 
2020-01-03 11:20:41.284  INFO 27988 --- [/temp/spool_in/] c.v.t.g.webservice.camel.VideoProcessor  : Processing Video_2.mpg video 
2020-01-03 11:20:53.342  INFO 27988 --- [/temp/spool_in/] c.v.t.g.webservice.camel.VideoProcessor  : Processing Video_3.mpg video 

以及移动的文件：