From fa6b15215371132116c05f541cf20e9ae2c4bfb9 Mon Sep 17 00:00:00 2001 From: MichMich <12600416+mmichailidis@users.noreply.github.com> Date: Fri, 21 Jan 2022 10:16:36 +0200 Subject: [PATCH] Added close on the channel after a port failure #276 --- .../biz/paluch/logging/gelf/intern/sender/AbstractNioSender.java | 1 + 1 file changed, 1 insertion(+) 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 index 9444b4992..b7af2731a 100644 --- 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);