diff --git a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean.java b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean.java index 186c666044..0c03dfec1e 100644 --- a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean.java +++ b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean.java @@ -40,6 +40,8 @@ import com.jcraft.jsch.ChannelSftp; * Factory bean to hide the fairly complex configuration possibilities for an SFTP endpoint * * @author Josh Long + * @author Oleg Zhurakousky + * @since 2.0 */ class SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean extends AbstractFactoryBean implements ResourceLoaderAware { @@ -60,26 +62,12 @@ class SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean private volatile SftpSessionFactory sftpSessionFactory; - public void setSftpSessionFactory(SftpSessionFactory sftpSessionFactory) { this.sftpSessionFactory = sftpSessionFactory; } - // private int port = 22; -// -// private String host; -// -// private String keyFile; -// -// private String keyFilePassword; -// private String remoteDirectory; -// -// private String username; -// -// private String password; - public void setLocalDirectoryResource(Resource localDirectoryResource) { this.localDirectoryResource = localDirectoryResource; @@ -105,43 +93,12 @@ class SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean this.filter = filter; } -// public void setPort(int port) { -// this.port = port; -// } -// -// public void setHost(String host) { -// this.host = host; -// } -// -// public void setKeyFile(String keyFile) { -// this.keyFile = keyFile; -// } -// -// public void setKeyFilePassword(String keyFilePassword) { -// this.keyFilePassword = keyFilePassword; -// } - /** * Set the remote directory to synchronize with */ public void setRemoteDirectory(String remoteDirectory) { this.remoteDirectory = remoteDirectory; } -// -// /** -// * Set the user name to be used for authentication with the remote server -// */ -// public void setUsername(String username) { -// this.username = username; -// } -// -// /** -// * Set the password to be used for authentication with the remote server -// * @param password -// */ -// public void setPassword(String password) { -// this.password = password; -// } /** * {@inheritDoc} @@ -190,9 +147,6 @@ class SftpInboundRemoteFileSystemSynchronizingMessageSourceFactoryBean this.filter = compositeFtpFileListFilter; // pools - - //SftpSession session = new Sf - //SftpSessionFactory sessionFactory = SftpSessionUtils.buildSftpSessionFactory(this.host, this.password, this.username, this.keyFile, this.keyFilePassword, this.port); QueuedSftpSessionPool pool = new QueuedSftpSessionPool(15, sftpSessionFactory); pool.afterPropertiesSet(); diff --git a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpSendingMessageHandlerFactoryBean.java b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpSendingMessageHandlerFactoryBean.java index f819a73c13..8e93e77d74 100644 --- a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpSendingMessageHandlerFactoryBean.java +++ b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/config/SftpSendingMessageHandlerFactoryBean.java @@ -28,23 +28,13 @@ import org.springframework.integration.sftp.session.SftpSessionFactory; * and send them to a remote destination. * * @author Josh Long + * @author Oleg Zhurakousky + * @since 2.0 */ class SftpSendingMessageHandlerFactoryBean implements FactoryBean { -// private String host; -// -// private String keyFile; -// -// private String keyFilePassword; -// -// private String password; - private Expression remoteDirectoryExpression; -// private String username; -// -// private int port; - private volatile SftpSessionFactory sftpSessionFactory; public void setSftpSessionFactory(SftpSessionFactory sftpSessionFactory) { @@ -58,30 +48,6 @@ class SftpSendingMessageHandlerFactoryBean implements FactoryBean { diff --git a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundRemoteFileSystemSynchronizingMessageSource.java b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundRemoteFileSystemSynchronizingMessageSource.java index cc39dbd0f5..45f6269094 100644 --- a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundRemoteFileSystemSynchronizingMessageSource.java +++ b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundRemoteFileSystemSynchronizingMessageSource.java @@ -28,6 +28,8 @@ import org.springframework.util.Assert; * a {@link org.springframework.integration.core.MessageSource} implementation for SFTP * * @author Josh Long + * @author Oleg Zhurakousky + * @since 2.0 */ public class SftpInboundRemoteFileSystemSynchronizingMessageSource extends AbstractInboundRemoteFileSystemSynchronizingMessageSource { /** diff --git a/spring-integration-sftp/src/main/resources/org/springframework/integration/sftp/config/spring-integration-sftp-2.0.xsd b/spring-integration-sftp/src/main/resources/org/springframework/integration/sftp/config/spring-integration-sftp-2.0.xsd index 2278e4e55c..7633181e06 100644 --- a/spring-integration-sftp/src/main/resources/org/springframework/integration/sftp/config/spring-integration-sftp-2.0.xsd +++ b/spring-integration-sftp/src/main/resources/org/springframework/integration/sftp/config/spring-integration-sftp-2.0.xsd @@ -32,14 +32,8 @@ - - - - - - @@ -83,14 +77,8 @@ - - - - - -