3

我可能遗漏了一些东西，但这就是正在发生的事情。

这有效：我在todo文件夹中有两个文件。如果我创建这条路线一切正常，我收到两个交换，每个文件一个，每 30 秒：

    from(String.format(baseFtpConnectionString, "/todo/") + "&scheduler=quartz2&scheduler.cron=0/10+*+*+*+*+?")
    .to("log:test?showAll=true&multiline=true")
    .unmarshal(bindyRegister)
    .process(new Processor() {                  
      @Override
      public void process(Exchange exchange) throws Exception {
          System.out.println("Ok");            
      }
    })
    .end();

问题：但是，如果我创建这条路线，每 30 秒接收一次交换，在两个文件之间切换。

  from("quartz2://getData?cron=0/10+*+*+*+*+?")
  .pollEnrich(String.format(baseFtpConnectionString, "/todo/"))
  .to("log:test?showAll=true&multiline=true")
  .unmarshal(bindyRegister)
  .process(new Processor() {                  
    @Override
    public void process(Exchange exchange) throws Exception {
        System.out.println("Ok");            
    }
  })
  .end();

baseFtpConnectionString 中的 ftp url 在 String.format 之后是这样的：

ftps://user@path:port/path?password=password&passiveMode=true

为什么 pollEnrich 不给我发送两个交流？它不应该具有与 from 语句相同的行为吗？

编辑 1

有没有办法使用poolEnrich(Recieve all the exchange, for both files) 来做到这一点？

编辑 2

显然没有。那么，除了链接上的文件之外，还有其他方法可以从ftp组件上加载所有文件吗？direct

4

1 回答 1

4

不，它不一样。

投票丰富一次仅丰富一条消息。

于 2016-05-13T06:02:25.240 回答