diff --git a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizer.java b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizer.java index 9813b973ab..fb0d77a572 100644 --- a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizer.java +++ b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizer.java @@ -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; diff --git a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizingMessageSource.java b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizingMessageSource.java index 193cb5eb80..f94cb5f01b 100644 --- a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizingMessageSource.java +++ b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundFileSynchronizingMessageSource.java @@ -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 synchronizer) { - super.setSynchronizer(synchronizer); - } - - @Override - protected void onInit() { - super.onInit(); - } - } diff --git a/spring-integration-ftp/src/test/java/org/springframework/integration/ftp/config/FtpInboundOutboundSanitySample.java b/spring-integration-ftp/src/test/java/org/springframework/integration/ftp/config/FtpInboundOutboundSanitySample.java index 67c748ceef..cec4464110 100644 --- a/spring-integration-ftp/src/test/java/org/springframework/integration/ftp/config/FtpInboundOutboundSanitySample.java +++ b/spring-integration-ftp/src/test/java/org/springframework/integration/ftp/config/FtpInboundOutboundSanitySample.java @@ -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()); }