ftp - Mule Quartz 轮询 FTP 端点

Question

我正在使用石英轮询器来轮询 FTP 端点，但我的问题是，当轮询器运行时，它不会从给定的路径或目录中选择超过 1 个文件，它只会选择一个文件。我们如何才能在轮询器启动时获取每个文件。?

感谢期待。

Answer 1

我遇到了同样的问题，并使用 2 个单独的流程解决了它。还使用了一个自定义接收器来避免删除远程文件，并使用一个 java 组件来通知作业完成，请参见以下流程：

<ftp:connector name="ftp-connector" passive="true" streaming="true" binary="true">
    <service-overrides messageReceiver="app.NonDeletingFtpMessageReceiver" />
</ftp:connector>

<ftp:endpoint name="ftp-fetch" connector-ref="ftp-connector"
    host="${pr.ftp.host}" port="${pr.ftp.port}" path="${pr.ftp.remotePath}"
    user="${pr.ftp.user}" password="${pr.ftp.password}">
    <file:filename-wildcard-filter pattern="${pr.ftp.filePattern}" />
</ftp:endpoint>

<quartz:endpoint name="quartz-batch" jobName="cron-job"
    cronExpression="${pr.ftp.cron}" responseTimeout="${pr.ftp.timeout}">
    <quartz:event-generator-job />
</quartz:endpoint>


<flow name="ftp-scheduler-flow" doc:name="ftp-scheduler-flow">
    <inbound-endpoint ref="quartz-batch" />
    <echo-component />
    <flow-ref name="ftp-process-fetch-flow" />
    <component class="app.FTPFetchHandler" />
</flow>

<flow name="ftp-process-fetch-flow">
    <inbound-endpoint ref="ftp-fetch" />
    <expression-filter evaluator="header"
        expression="originalFilename!=null" />
    <file:outbound-endpoint path="${pr.ftp.localPath}"
        responseTimeout="${pr.ftp.timeout}" outputPattern="#[header:originalFilename]" />
</flow>

Answer 2

石英轮询端点消息源设计为在每次触发时处理单个 mule 事件，因此根据设计它只会消耗一个文件。

这被报告为一个错误，但查看代码可能应该将其归类为增强请求。

要获得不同的行为，您应该编写自己的自定义组件并使用它从 ftp 检索所有文件，或者依赖 ftp 传输本身。

高温高压