diff --git a/modules/src/main/java/org/archive/modules/fetcher/FetchFTP.java b/modules/src/main/java/org/archive/modules/fetcher/FetchFTP.java index a10029f4..ee37d5cb 100644 --- a/modules/src/main/java/org/archive/modules/fetcher/FetchFTP.java +++ b/modules/src/main/java/org/archive/modules/fetcher/FetchFTP.java @@ -325,9 +325,9 @@ public class FetchFTP extends Processor { private void saveToRecorder(ProcessorURI curi, Socket socket, Recorder recorder) throws IOException, InterruptedException { - recorder.markContentBegin(); recorder.inputWrap(socket.getInputStream()); recorder.outputWrap(socket.getOutputStream()); + recorder.markContentBegin(); // Read the remote file/dir listing in its entirety. long softMax = 0;