ReliableMulticast.close()

1 files changed, 10 insertions, 0 deletions

diff --git a/src/main/java/derms/net/ConcurrentMulticastSocket.java b/src/main/java/derms/net/ConcurrentMulticastSocket.java
index 24a040c..6aeb5a8 100644
--- a/src/main/java/derms/net/ConcurrentMulticastSocket.java
+++ b/src/main/java/derms/net/ConcurrentMulticastSocket.java
@@ -4,6 +4,8 @@ import java.io.IOException;
 import java.net.DatagramPacket;
 import java.net.InetAddress;
 import java.net.MulticastSocket;
+import java.net.SocketException;
+import java.time.Duration;
 
 public class ConcurrentMulticastSocket {
     private final MulticastSocket sock;
@@ -31,6 +33,14 @@ public class ConcurrentMulticastSocket {
         sock.receive(p);
     }
 
+    public synchronized void setSoTimeout(Duration timeout) throws SocketException {
+        sock.setSoTimeout((int) timeout.toMillis());
+    }
+
+    public synchronized void close() {
+        sock.close();
+    }
+
     @Override
     public String toString() {
         return sock.getLocalSocketAddress().toString();