java - Camel pollEnrich 第二次没有工作

Question

我正在读取和处理来自 2 个不同文件位置的 2 个文件并比较内容。如果第二个文件不可用，则其余过程将使用第一个文件执行。如果第二个文件可用，比较过程应该发生。为此，我正在使用 camel pollEnrich，但这里的问题是，camel 仅在第一次选择第二个文件。如果不重新启动 Camel 路线，第二个文件即使存在也不会被拾取。重新启动 Camel 路线后，它工作正常，但之后它没有选择第二个文件。

我正在将文件处理后移动到不同的位置。

下面是我的代码，

from("sftp:" + firstFileLocation + "?privateKeyFile=" + ppkFileLocation + "&username=" + sftpUsername
            + "&readLock=changed&idempotent=true&move=" + firstFileArchiveLocation)
    .pollEnrich("sftp:" + secondFileLocation + "?privateKeyFile=" + ppkFileLocation + "&username=" + sftpUsername
            + "&readLock=changed&idempotent=true&fileExist=Ignore&move="+ secondFileLocationArchive ,10000,new FileAggregationStrategy())
    .routeId("READ_INPUT_FILE_ROUTE")

需要帮助。

Answer 1

您在 sftp 消费者中设置 idempotent=true，这意味着 camel 不会处理相同的文件名两次。由于您正在移动文件，因此设置 idempotent=false 是有意义的。

引自 Camel documentation

Option to use the Idempotent Consumer EIP pattern to let Camel skipalready processed files. Will by default use a memory based LRUCachethat holds 1000 entries. If noop=true then idempotent will be enabledas well to avoid consuming the same files over and over again.