From c281c7cbb8f1e044c3d4f4409cbbfcaf73fa40c9 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sat, 16 Nov 2024 12:55:50 -0500
Subject: reliable multicast: bind receiving socket to group port

---
 src/main/java/derms/net/rmulticast/ReliableMulticast.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src')

diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
index 039e790..19b7bd7 100644
--- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java
+++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
@@ -47,14 +47,14 @@ public class ReliableMulticast<T extends MessagePayload> {
         this.retransmissions = new LinkedBlockingQueue<Message<T>>();
         this.groupMembers = new ConcurrentHashMap<InetAddress, Void>().keySet();
 
-        this.outSock = new ConcurrentMulticastSocket(group.getPort());
+        this.outSock = new ConcurrentMulticastSocket();
         this.outSock.joinGroup(group.getAddress());
 
         this.delivered = new LinkedBlockingQueue<Message<T>>();
 
         this.log = Logger.getLogger(this.getClass().getName());
 
-        ConcurrentMulticastSocket inSock = new ConcurrentMulticastSocket();
+        ConcurrentMulticastSocket inSock = new ConcurrentMulticastSocket(group.getPort());
         inSock.joinGroup(group.getAddress());
         (new Thread(new Receive<T>(inSock, acks, nacks, received, retransmissions, groupMembers, delivered))).start();
 
-- 
cgit v1.2.3