diff options
Diffstat (limited to 'src/main/java/derms/net')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/ReliableMulticast.java | 4 |
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(); |