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

INT-1704 changed to pass the full file path when calling session.rename(fromPath, toPath) instead of just a file name

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-12-21 15:33:41 -05:00
parent 334a8070a9
commit fe6ff2aa98
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -55,7 +55,7 @@ public class FileTransferringMessageHandler extends AbstractMessageHandler {
private volatile File temporaryDirectory = new File(System.getProperty("java.io.tmpdir")); private volatile File temporaryDirectory = new File(System.getProperty("java.io.tmpdir"));
private volatile String charset = "UTF-8"; private volatile String charset = "UTF-8";
public FileTransferringMessageHandler(SessionFactory sessionFactory) { public FileTransferringMessageHandler(SessionFactory sessionFactory) {
Assert.notNull(sessionFactory, "sessionFactory must not be null"); Assert.notNull(sessionFactory, "sessionFactory must not be null");
@@ -155,7 +155,7 @@ public class FileTransferringMessageHandler extends AbstractMessageHandler {
} }
} }
private void sendFileToRemoteDirectory(File file, String remoteDirectory, String pathTo, Session session) private void sendFileToRemoteDirectory(File file, String remoteDirectory, String fileName, Session session)
throws FileNotFoundException, IOException { throws FileNotFoundException, IOException {
FileInputStream fileInputStream = new FileInputStream(file); FileInputStream fileInputStream = new FileInputStream(file);
@@ -167,7 +167,7 @@ public class FileTransferringMessageHandler extends AbstractMessageHandler {
session.write(fileInputStream, remoteFilePath); session.write(fileInputStream, remoteFilePath);
fileInputStream.close(); fileInputStream.close();
// then rename it to its final name // then rename it to its final name
session.rename(remoteFilePath, pathTo); session.rename(remoteFilePath, remoteDirectory + fileName);
} }
} }