Repository: qpid-broker-j
Updated Branches:
  refs/heads/master 626666a07 -> 2422183b6


QPID-7399: [Broker-J] Catch ClosedSelectorException which can occur during 
shutdown


Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/2422183b
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/2422183b
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/2422183b

Branch: refs/heads/master
Commit: 2422183b6a9d9bedf1aebd218e693bb3e82eeca1
Parents: 626666a
Author: Lorenz Quack <lqu...@apache.org>
Authored: Fri Oct 27 14:23:01 2017 +0100
Committer: Lorenz Quack <lqu...@apache.org>
Committed: Fri Oct 27 14:25:29 2017 +0100

----------------------------------------------------------------------
 .../java/org/apache/qpid/server/transport/SelectorThread.java | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/2422183b/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java
----------------------------------------------------------------------
diff --git 
a/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java
 
b/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java
index a64d655..92f6bbc 100644
--- 
a/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java
+++ 
b/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java
@@ -210,6 +210,13 @@ class SelectorThread extends Thread
                                     channel.register(_selector, 
SelectionKey.OP_ACCEPT, transport);
                                     wakeup();
                                 }
+                                catch (ClosedSelectorException e)
+                                {
+                                    LOGGER.info(
+                                            "Failed to register selector on 
accepting port {} because selector is"
+                                            + " already closed. This is 
probably a harmless race-condition (QPID-7399)",
+                                            localSocketAddress);
+                                }
                                 catch (ClosedChannelException e)
                                 {
                                     LOGGER.error("Failed to register selector 
on accepting port {}",


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org

Reply via email to