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

INT-1614 removed unnecessary code from FtpInboundFileSynchronizingMessageSource

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-11-19 15:53:34 -05:00
parent c7c0972ce2
commit dcfb51c0cd
3 changed files with 1 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -23,13 +23,10 @@ import java.io.IOException;
import java.io.InputStream;
import java.util.Collection;
import org.apache.commons.io.IOUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.io.CopyStreamEvent;
import org.apache.commons.net.io.Util;
import org.springframework.core.io.Resource;
import org.springframework.integration.MessagingException;

12
spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizingMessageSource.java
View File

@@ -18,7 +18,6 @@ package org.springframework.integration.ftp.inbound;
import org.apache.commons.net.ftp.FTPFile;
import org.springframework.integration.file.synchronizer.AbstractInboundFileSynchronizer;
import org.springframework.integration.file.synchronizer.AbstractInboundFileSynchronizingMessageSource;
/**
@@ -32,15 +31,4 @@ public class FtpInboundFileSynchronizingMessageSource extends AbstractInboundFil
public String getComponentType() {
return "ftp:inbound-channel-adapter";
}
@Override
public void setSynchronizer(AbstractInboundFileSynchronizer<FTPFile> synchronizer) {
super.setSynchronizer(synchronizer);
}
@Override
protected void onInit() {
super.onInit();
}
}

2
spring-integration-ftp/src/test/java/org/springframework/integration/ftp/config/FtpInboundOutboundSanitySample.java
View File

@@ -57,7 +57,7 @@ public class FtpInboundOutboundSanitySample {
new ClassPathXmlApplicationContext("FtpInboundChannelAdapterSample-context.xml", this.getClass());
Thread.sleep(3000);
fileA = new File("local-test-dir/b.test");
fileB = new File("local-test-dir/b.test");
fileB = new File("local-test-dir/b.test");
assertTrue(fileA.exists());
assertTrue(fileB.exists());
}