Handle exception in NIO loop to avoid abrupt termination

acogoluegnes · acogoluegnes · commit bd385248f877 · 2019-05-16T10:31:26.000+02:00
Fixes rabbitmq#611
diff --git a/src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java b/src/main/java/com/rabbitmq/client/impl/nio/NioLoop.java
@@ -115,7 +115,14 @@ public void run() {
                     registration = registrationIterator.next();
                     registrationIterator.remove();
                     int operations = registration.operations;
-                    registration.state.getChannel().register(selector, operations, registration.state);
+                    try {
+                        if (registration.state.getChannel().isOpen()) {
+                            registration.state.getChannel().register(selector, operations, registration.state);
+                        }
+                    } catch (Exception e) {
+                        // can happen if the channel has been closed since the operation has been enqueued
+                        LOGGER.info("Error while registering socket channel for read: {}", e.getMessage());
+                    }
                 }
 
                 if (select > 0) {
