Repository: activemq Updated Branches: refs/heads/activemq-5.15.x 592b31343 -> 3ef457125
AMQ-6820 - Properly handle ClosedChannelException When a ClosedChannelException occurs inside SelectorSelection properly call the transport listener onError() method to handle cleanup and logging. (cherry picked from commit 6e33507bf2fc2acea9f61e230cf8e2a9cbccc3ce) Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/3ef45712 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/3ef45712 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/3ef45712 Branch: refs/heads/activemq-5.15.x Commit: 3ef457125b11decc4e9b03dfbbc3e926725ff91c Parents: 592b313 Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Authored: Thu Sep 21 08:13:42 2017 -0400 Committer: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com> Committed: Thu Sep 21 08:15:02 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/3ef45712/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); } } });
