diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/ftp/FtpTarget.java b/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/ftp/FtpTarget.java index 2c7a8d623d..726ce7b01b 100644 --- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/ftp/FtpTarget.java +++ b/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/ftp/FtpTarget.java @@ -38,7 +38,7 @@ public class FtpTarget implements MessageTarget { private final MessageMapper messageMapper; - private volatile QueuedFTPClientPool ftpClientPool = new QueuedFTPClientPool(); + private volatile FTPClientPool ftpClientPool = new QueuedFTPClientPool(); public FtpTarget(MessageMapper messageMapper) { @@ -47,7 +47,7 @@ public class FtpTarget implements MessageTarget { } - public void setFtpClientPool(QueuedFTPClientPool ftpClientPool) { + public void setFtpClientPool(FTPClientPool ftpClientPool) { Assert.notNull(ftpClientPool, "ftpClientPool must not be null"); this.ftpClientPool = ftpClientPool; }