Apache camel-使用直接组件调用文件endpoint

Question

我需要在调用SFTPendpoint之前调用特定逻辑。考虑中的逻辑将在exchange中注入一些标头。当SFTP路由启动时，将使用这些标头。

因此，我试图在第一次计时时调用我的初始设置逻辑。它只会运行一次。某些标头将设置在exchange对象内。然后，在完成此操作后，应调用文件endpoint。标头应流经在这些endpoint之间传递的exchange对象。

我试着探索这个的直接组件。我试过这样的

from("timer://cacheEntryCount?repeatCount=1")
.process(new Processor() {
    @Override
    public void process(Exchange exchange) throws Exception
    {
        logger.info("setting count");
        exchange.getIn().setHeader("count",1);
    }
})
.to("direct:"+fileUrl);

from("direct:"+fileUrl)
  ....
  ....
  .process(new Processor() {
        @Override
    public void process(Exchange exchange) throws Exception
    {
        logger.info("accessing count");
        exchange.getIn().getHeader("count");
    }
  ....

其中fileUrl=file:/tmp/refDataFiles？字符集=UTF-8

但这给了我以下的错误

无法解析endpoint：Direct：//file：/temp/refDataFiles？ charset=UTF-8，原因是：有1个参数无法在endpoint上设置。检查uri参数是否拼写正确并且它们是endpoint的属性。未知参数=[{charset=UTF-8}]

这里如何进行？请帮忙。




Answer 1

此错误意味着直接endpoint不支持将字符集作为查询参数的名称，因为它不是文档中所示列表的一部分。

这里的问题是，在运行时URI是<代码>direct://file:/temp/refDataFiles?charset=UTF-Camel将其解释为一个URI，引用直接endpoint，名称为file:/temp/refDataFiles，查询参数为charset=UTF-8。

我不确定我是否真的明白您要做的事情，但您显然混合了无法工作的Direct和fileendpoint。