Added close on the channel after a port failure #276

mp911de · Jan 21, 2022 · fa6b152 · fa6b152
1 parent 6ff4e5c
commit fa6b152
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/biz/paluch/logging/gelf/intern/sender/AbstractNioSender.java b/src/main/java/biz/paluch/logging/gelf/intern/sender/AbstractNioSender.java
@@ -78,6 +78,7 @@ protected boolean isConnected() throws IOException {
                 return myChannel.read(byteBuffer) >= 0;
             } catch (PortUnreachableException e) {
                 errorReporter.reportError("Port " + getHost() + ":" + getPort() + " not reachable", e);
+                Closer.close(channel());
             } catch (IOException e) {
                 errorReporter.reportError("Cannot verify whether channel to " + getHost() + ":" + getPort() + " is connected: "
                         + e.getMessage(), e);