Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1936 fixed FileTransferingMessageHandler to ensure it closes the input stream in cases when Exception is thrown during session.write(..)

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-06-23 14:46:41 -04:00
parent 987656ee02
commit 703a531cb0
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-integration-file/src/main/java/org/springframework/integration/file/remote/handler/FileTransferringMessageHandler.java
View File

@@ -196,10 +196,17 @@ public class FileTransferringMessageHandler extends AbstractMessageHandler {
this.ensureDirectoryExists(session, remoteDirectory, remoteDirectory);
}
session.write(fileInputStream, tempFilePath);
fileInputStream.close();
// then rename it to its final name
session.rename(tempFilePath, remoteFilePath);
try {
session.write(fileInputStream, tempFilePath);
// then rename it to its final name
session.rename(tempFilePath, remoteFilePath);
}
catch (Exception e) {
throw new MessagingException("Failed to write to '" + tempFilePath + "' while uploading the file", e);
}
finally {
fileInputStream.close();
}
}
private void ensureDirectoryExists(Session session, String remoteDirectory, String originalRemoteDirectory){