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

Question

我有一个非常简单的配置，将文件从 FTP 服务器复制到文件出站。由于文件大小巨大，我使用流进行文件传输。这是我的配置:

 <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>

我不知道如何关闭输入流，以便文件在复制后从 FTP 服务器中删除。

Answer 1

由于有效负载是一个InputStream，因此 file outbound endpoint dispatcher 的以下代码将被执行:

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

因此该流应该会自动为您关闭。