使用流式传输时如何在 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

由于payload是InputStream，下面的file outbound endpoint dispatcher代码会被执行：

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

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