Implement Closeable - fix #25

Author: Cyrille Le Clerc

src/main/java/com/cloudbees/syslog/sender/SyslogMessageSender.java

@@ -22,6 +22,7 @@
 import javax.annotation.Nullable;
 import javax.annotation.concurrent.ThreadSafe;
 import java.io.CharArrayWriter;
+import java.io.Closeable;
 import java.io.IOException;
 import java.util.concurrent.TimeUnit;
 
@@ -33,7 +34,7 @@
  * @author <a href="mailto:[email protected]">Cyrille Le Clerc</a>
  */
 @ThreadSafe
-public interface SyslogMessageSender {
+public interface SyslogMessageSender extends Closeable {
     public static final long DEFAULT_INET_ADDRESS_TTL_IN_MILLIS = TimeUnit.MILLISECONDS.convert(30, TimeUnit.SECONDS);
     public static final long DEFAULT_INET_ADDRESS_TTL_IN_NANOS = TimeUnit.NANOSECONDS.convert(DEFAULT_INET_ADDRESS_TTL_IN_MILLIS, TimeUnit.MILLISECONDS);
     public static final String DEFAULT_SYSLOG_HOST = "localhost";

src/main/java/com/cloudbees/syslog/sender/TcpSyslogMessageSender.java

@@ -27,6 +27,7 @@
 import javax.net.ssl.SSLSocket;
 import javax.net.ssl.SSLSocketFactory;
 import java.io.BufferedWriter;
+import java.io.Closeable;
 import java.io.IOException;
 import java.io.OutputStreamWriter;
 import java.io.Writer;
@@ -44,7 +45,7 @@
  * @author <a href="mailto:[email protected]">Cyrille Le Clerc</a>
  */
 @ThreadSafe
-public class TcpSyslogMessageSender extends AbstractSyslogMessageSender {
+public class TcpSyslogMessageSender extends AbstractSyslogMessageSender implements Closeable  {
     public final static int SETTING_SOCKET_CONNECT_TIMEOUT_IN_MILLIS_DEFAULT_VALUE = 500;
     public final static int SETTING_MAX_RETRY = 2;
 
@@ -269,4 +270,9 @@ public String toString() {
                 ", trySendErrorCounter=" + trySendErrorCounter +
                 '}';
     }
+
+    @Override
+    public void close() throws IOException {
+        this.socket.close();
+    }
 }

src/main/java/com/cloudbees/syslog/sender/UdpSyslogMessageSender.java

@@ -21,6 +21,7 @@
 import javax.annotation.Nullable;
 import javax.annotation.concurrent.ThreadSafe;
 import java.io.ByteArrayOutputStream;
+import java.io.Closeable;
 import java.io.IOException;
 import java.io.OutputStreamWriter;
 import java.io.Writer;
@@ -39,7 +40,7 @@
  * @author <a href="mailto:[email protected]">Cyrille Le Clerc</a>
  */
 @ThreadSafe
-public class UdpSyslogMessageSender extends AbstractSyslogMessageSender {
+public class UdpSyslogMessageSender extends AbstractSyslogMessageSender implements Closeable {
     /**
      * {@link java.net.InetAddress InetAddress} of the remote Syslog Server.
      *
@@ -147,4 +148,9 @@ public String toString() {
                 ", sendErrorCounter=" + sendErrorCounter +
                 '}';
     }
+
+    @Override
+    public void close() throws IOException {
+        this.datagramSocket.close();
+    }
 }