activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cshan...@apache.org
Subject activemq git commit: AMQ-6820 - Properly handle ClosedChannelException
Date Thu, 21 Sep 2017 12:14:32 GMT
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) <christopher.l.shannon@gmail.com>
Authored: Thu Sep 21 08:13:42 2017 -0400
Committer: Christopher L. Shannon (cshannon) <christopher.l.shannon@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);
                 }
             }
         });


Mime
View raw message