From 4382f9dcbe097b86c957ba028e2bcab6ca384f58 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sun, 1 Dec 2024 20:50:33 -0500
Subject: pass NetworkInterface to TotalOrderMulticastReceiver

---
 src/main/java/derms/net/tomulticast/Receive.java | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'src/main/java/derms/net/tomulticast/Receive.java')

diff --git a/src/main/java/derms/net/tomulticast/Receive.java b/src/main/java/derms/net/tomulticast/Receive.java
index e89ae1b..6bc2df5 100644
--- a/src/main/java/derms/net/tomulticast/Receive.java
+++ b/src/main/java/derms/net/tomulticast/Receive.java
@@ -5,6 +5,7 @@ import derms.net.MessagePayload;
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
+import java.net.NetworkInterface;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.PriorityBlockingQueue;
 
@@ -17,6 +18,12 @@ class Receive<T extends MessagePayload> extends TotalOrderMulticast<T> implement
     private final PriorityBlockingQueue<Message<T>> holdback;
     private final BlockingQueue<Message<T>> deliver;
 
+    Receive(InetSocketAddress group, InetAddress laddr, BlockingQueue<Message<T>> deliver, NetworkInterface ifs) throws IOException {
+        super(group, laddr, ifs);
+        this.holdback = new PriorityBlockingQueue<Message<T>>();
+        this.deliver = deliver;
+    }
+
     Receive(InetSocketAddress group, InetAddress laddr, BlockingQueue<Message<T>> deliver) throws IOException {
         super(group, laddr);
         this.holdback = new PriorityBlockingQueue<Message<T>>();
-- 
cgit v1.2.3