From 0d8d7b43c7ff0a0cf45a51b505aa128f43f13f5c Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 19 Dec 2011 16:48:23 -0500 Subject: [PATCH] create FileInputStream as late as possible --- .../file/remote/handler/FileTransferringMessageHandler.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/spring-integration-file/src/main/java/org/springframework/integration/file/remote/handler/FileTransferringMessageHandler.java b/spring-integration-file/src/main/java/org/springframework/integration/file/remote/handler/FileTransferringMessageHandler.java index 8a58c095c9..c8117d9491 100644 --- a/spring-integration-file/src/main/java/org/springframework/integration/file/remote/handler/FileTransferringMessageHandler.java +++ b/spring-integration-file/src/main/java/org/springframework/integration/file/remote/handler/FileTransferringMessageHandler.java @@ -194,9 +194,6 @@ public class FileTransferringMessageHandler extends AbstractMessageHandler { private void sendFileToRemoteDirectory(File file, String temporaryRemoteDirectory, String remoteDirectory, String fileName, Session session) throws FileNotFoundException, IOException { - - FileInputStream fileInputStream = new FileInputStream(file); - remoteDirectory = this.normalizeDirectoryPath(remoteDirectory); temporaryRemoteDirectory = this.normalizeDirectoryPath(temporaryRemoteDirectory); @@ -207,6 +204,7 @@ public class FileTransferringMessageHandler extends AbstractMessageHandler { if (this.autoCreateDirectory) { session.mkdir(remoteDirectory); } + FileInputStream fileInputStream = new FileInputStream(file); try { session.write(fileInputStream, tempFilePath); // then rename it to its final name