diff --git a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/config/FtpInboundSynchronizingMessageSourceFactoryBean.java b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/config/FtpInboundSynchronizingMessageSourceFactoryBean.java index c47008b7d9..ad3517cd63 100644 --- a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/config/FtpInboundSynchronizingMessageSourceFactoryBean.java +++ b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/config/FtpInboundSynchronizingMessageSourceFactoryBean.java @@ -132,7 +132,6 @@ class FtpInboundSynchronizingMessageSourceFactoryBean synchronizer.setFilter(compositeFilter); messageSource.setRemotePredicate(compositeFilter); messageSource.setSynchronizer(synchronizer); - messageSource.setClientPool(queuedFtpClientPool); messageSource.setLocalDirectory(this.localDirectoryResource); messageSource.setBeanFactory(this.getBeanFactory()); messageSource.setAutoStartup(true); diff --git a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundRemoteFileSystemSynchronizingMessageSource.java b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundRemoteFileSystemSynchronizingMessageSource.java index 199a07fab8..298dd3a94f 100644 --- a/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundRemoteFileSystemSynchronizingMessageSource.java +++ b/spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundRemoteFileSystemSynchronizingMessageSource.java @@ -20,7 +20,6 @@ import org.apache.commons.net.ftp.FTPFile; import org.springframework.integration.file.synchronizer.AbstractInboundFileSynchronizer; import org.springframework.integration.file.synchronizer.AbstractInboundFileSynchronizingMessageSource; -import org.springframework.integration.ftp.client.FtpClientPool; /** * A {@link org.springframework.integration.core.MessageSource} implementation for FTP. @@ -30,13 +29,6 @@ import org.springframework.integration.ftp.client.FtpClientPool; */ public class FtpInboundRemoteFileSystemSynchronizingMessageSource extends AbstractInboundFileSynchronizingMessageSource { - private volatile FtpClientPool clientPool; - - - public void setClientPool(FtpClientPool clientPool) { - this.clientPool = clientPool; - } - public String getComponentType() { return "ftp:inbound-channel-adapter"; } @@ -49,9 +41,6 @@ public class FtpInboundRemoteFileSystemSynchronizingMessageSource extends Abstra @Override protected void onInit() { super.onInit(); - if (this.synchronizer instanceof FtpInboundRemoteFileSystemSynchronizer) { - ((FtpInboundRemoteFileSystemSynchronizer) this.synchronizer).setClientPool(this.clientPool); - } } }