diff --git a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundFileSynchronizer.java b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundFileSynchronizer.java index a554bf3b9a..4a5de26cc5 100644 --- a/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundFileSynchronizer.java +++ b/spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundFileSynchronizer.java @@ -91,7 +91,14 @@ public class SftpInboundFileSynchronizer extends AbstractInboundFileSynchronizer throw new MessagingException("couldn't synchronize remote to local directory", e); } finally { - session.close(); + try { + session.close(); + } + catch (Exception ignored) { + if (logger.isDebugEnabled()) { + logger.debug("failed to close Session", ignored); + } + } if (logger.isTraceEnabled()) { logger.trace("Putting SftpSession " + session + " back into the pool"); }