Close the session when an exception is caught while flushing the session. Project: http://git-wip-us.apache.org/repos/asf/mina/repo Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/40634db1 Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/40634db1 Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/40634db1
Branch: refs/heads/2.0 Commit: 40634db13455f4dffa781875285455004ff343a4 Parents: 1407818 Author: Emmanuel Lécharny <elecha...@symas.com> Authored: Fri Dec 4 23:06:08 2015 +0100 Committer: Emmanuel Lécharny <elecha...@symas.com> Committed: Fri Dec 4 23:06:08 2015 +0100 ---------------------------------------------------------------------- .../org/apache/mina/core/polling/AbstractPollingIoProcessor.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mina/blob/40634db1/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java ---------------------------------------------------------------------- diff --git a/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java b/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java index ad9ae5d..e6b141c 100644 --- a/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java +++ b/mina-core/src/main/java/org/apache/mina/core/polling/AbstractPollingIoProcessor.java @@ -788,6 +788,7 @@ public abstract class AbstractPollingIoProcessor<S extends AbstractIoSession> im } } catch (Exception e) { scheduleRemove(session); + session.close(true); IoFilterChain filterChain = session.getFilterChain(); filterChain.fireExceptionCaught(e); }
