You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cs...@apache.org on 2017/09/21 12:14:32 UTC
activemq git commit: AMQ-6820 - Properly handle ClosedChannelException
Repository: activemq
Updated Branches:
refs/heads/master 61d3231d3 -> 6e33507bf
AMQ-6820 - Properly handle ClosedChannelException
When a ClosedChannelException occurs inside SelectorSelection properly
call the transport listener onError() method to handle cleanup and
logging.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/6e33507b
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/6e33507b
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/6e33507b
Branch: refs/heads/master
Commit: 6e33507bf2fc2acea9f61e230cf8e2a9cbccc3ce
Parents: 61d3231
Author: Christopher L. Shannon (cshannon) <ch...@gmail.com>
Authored: Thu Sep 21 08:13:42 2017 -0400
Committer: Christopher L. Shannon (cshannon) <ch...@gmail.com>
Committed: Thu Sep 21 08:14:19 2017 -0400
----------------------------------------------------------------------
.../java/org/apache/activemq/transport/nio/SelectorSelection.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/6e33507b/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorSelection.java
----------------------------------------------------------------------
diff --git a/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorSelection.java b/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorSelection.java
index a0dd210..b0aafd2 100644
--- a/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorSelection.java
+++ b/activemq-client/src/main/java/org/apache/activemq/transport/nio/SelectorSelection.java
@@ -44,7 +44,7 @@ public final class SelectorSelection {
try {
SelectorSelection.this.key = selectable.register(worker.selector, 0, SelectorSelection.this);
} catch (Exception e) {
- e.printStackTrace();
+ onError(e);
}
}
});