diff options
Diffstat (limited to 'src/main/java/derms/net/tomulticast/Receive.java')
| -rw-r--r-- | src/main/java/derms/net/tomulticast/Receive.java | 7 |
1 files changed, 7 insertions, 0 deletions
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>>(); |