java - 使用流式传输时如何在 Mule 中关闭 FTP 入站端点的输入流

Question

我有一个非常简单的配置，它将文件从 FTP 服务器复制到文件出站。由于文件很大，我正在使用streaming文件传输。这是我的配置：

 <ftp:connector name="ftpConnector" streaming="true" pollingFrequency="360000"/>

    <flow name="copyFTPtoFile">
        <ftp:inbound-endpoint name="FTP" connector-ref="ftpConnector" host="FTP" port="21" user="test" password="test" path="/Testenv" />
        <file:outbound-endpoint path="/vendor/in" />
    </flow>

我不确定如何关闭文件，input-stream以便在复制文件后从 FTP 服务器中删除文件。

Answer 1

由于有效负载是，因此将执行文件出站端点调度InputStream程序的以下代码：

InputStream is = event.transformMessage(DataTypeFactory.create(InputStream.class));
IOUtils.copyLarge(is, fos);
is.close();

所以应该为你自动关闭流。