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

INT-1614 removed redundant setClientPool call

Browse Source
This commit is contained in:
Mark Fisher
2010-11-19 12:28:43 -05:00
parent ee6e079175
commit 46b4d8a595
2 changed files with 0 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-integration-ftp/src/main/java/org/springframework/integration/ftp/config/FtpInboundSynchronizingMessageSourceFactoryBean.java
View File

@@ -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);

11
spring-integration-ftp/src/main/java/org/springframework/integration/ftp/inbound/FtpInboundRemoteFileSystemSynchronizingMessageSource.java
View File

@@ -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<FTPFile> {
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);
}
}
}