Camel多次使用来自同一URI的PollRelch返回空正文

Question

我有两条路线。第一条路由使用poll enrich检查文件是否存在。第二条路由使用相同uri上的轮询丰富来读取和处理文件。第一条路由通过SEDA队列调用第二条路由,如下所示：

public void configure() throws Exception {
    String myFile = "file://myDir?fileName=MyFile.zip&delete=false&readLock=none";

    from("direct:test")
       .pollEnrich(myFile, 10000)
    .to("seda:myQueue")
    ;

    from("seda:myQueue")
        .pollEnrich(myFile, 10000)
        .log("Do something with the body")
    ;
}

照目前的情况，如果我执行第一条路由，则轮询充实将找到一个文件，但当第二条路由中的轮询充实执行时，它将返回一个空体。如果我只是单独执行第二条路由，它就会正确地检索文件。

为什么第二轮投票丰富返回空，文件锁定了吗？（我希望使用noop、readLock和delete=false的组合可以防止任何锁定）

您可能会奇怪为什么我要尝试从两条路由中进行丰富，第一条路由必须检查是否存在多个文件，只有当所有文件都存在时（即pollrelch不返回null），第二条路由才能开始处理它们。

有没有什么替代花粉的方法可以让我使用？我想也许我需要创建一个bean，它通过URI检索文件并将其作为正文返回。

我使用的是骆驼2.11.0

Answer 1

我意识到这是一个老话题了，但我刚刚遇到了一个类似的问题。
我建议您尝试以下选项：

noop=true

你已经有了，而且

idempotent=false

要告诉camelOK处理同一文件两次是OK。

测试后更新：

我实际上用上面建议的两种设置测试了它，它有时工作，但在中等负载下，它失败了，即对某些交换返回空体，尽管不是全部。