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

fixes INT-231 - FtpSource does not release connection

Browse Source
This commit is contained in:
Marius Bogoevici
2008-05-23 13:36:45 +00:00
parent f2c4f25bf0
commit c2728c2f17
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/ftp/FtpSource.java
View File

@@ -147,15 +147,20 @@ public class FtpSource implements Source<Object>, MessageDeliveryAware, Initiali
return this.messageCreator.createMessage(file);
}
catch (Exception e) {
throw new MessagingException("Error while polling for messages.", e);
}
finally {
try {
if (this.client.isConnected()) {
this.client.disconnect();
if (logger.isDebugEnabled()) {
logger.debug("connection closed");
}
}
}
catch (IOException ioe) {
throw new MessagingException("Error when disconnecting from ftp.", ioe);
}
throw new MessagingException("Error while polling for messages.", e);
}
}