reliable multicast: bind receiving socket to group port

1 files changed, 2 insertions, 2 deletions

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();