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

INT-1614 polished FTP synchronizer with changes from Oleg

Browse Source
This commit is contained in:
Mark Fisher
2010-11-20 16:31:16 -05:00
parent d8110b859c
commit 06f4bfda06
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizer.java
View File

@@ -33,6 +33,7 @@ import org.springframework.integration.file.remote.session.SessionFactory;
import org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer;
import org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizingMessageSource;
import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils;
import org.springframework.util.FileCopyUtils;
/**
@@ -69,27 +70,32 @@ public class FtpInboundFileSynchronizer extends AbstractInboundFileSynchronizer<
}
public void synchronizeToLocalDirectory(File localDirectory) {
Session session = null;
try {
Session session = this.sessionFactory.getSession();
session = this.sessionFactory.getSession();
Assert.state(session != null, "failed to acquire an FTP Session");
Collection<FTPFile> beforeFilter = session.ls(this.remotePath);
FTPFile[] entries = (beforeFilter == null) ? new FTPFile[0] :
beforeFilter.toArray(new FTPFile[beforeFilter.size()]);
Collection<FTPFile> fileList = this.filterFiles(entries);
try {
for (FTPFile ftpFile : fileList) {
Collection<FTPFile> files = session.ls(this.remotePath);
if (!CollectionUtils.isEmpty(files)) {
Collection<FTPFile> filteredFiles = this.filterFiles(files.toArray(new FTPFile[]{}));
for (FTPFile ftpFile : filteredFiles) {
if ((ftpFile != null) && ftpFile.isFile()) {
copyFileToLocalDirectory(session, ftpFile, localDirectory);
}
}
}
finally {
session.close();
}
}
catch (IOException e) {
throw new MessagingException("Problem occurred while synchronizing remote to local directory", e);
}
finally {
if (session != null) {
try {
session.close();
}
catch (Exception ignored) {
}
}
}
}
private boolean copyFileToLocalDirectory(Session session, FTPFile ftpFile, File localDirectory)