diff options
| -rw-r--r-- | src/main/java/derms/net/rmulticast/ReliableMulticast.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java index 19b7bd7..cfd4435 100644 --- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java +++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java @@ -41,11 +41,11 @@ public class ReliableMulticast<T extends MessagePayload> { this.group = group; this.laddr = laddr; - this.acks = new ConcurrentHashMap<MessageID, Void>().keySet(); - this.nacks = new ConcurrentHashMap<MessageID, Void>().keySet(); + this.acks = ConcurrentHashMap.newKeySet(); + this.nacks = ConcurrentHashMap.newKeySet(); this.received = new ReceivedSet<T>(); this.retransmissions = new LinkedBlockingQueue<Message<T>>(); - this.groupMembers = new ConcurrentHashMap<InetAddress, Void>().keySet(); + this.groupMembers = ConcurrentHashMap.newKeySet(); this.outSock = new ConcurrentMulticastSocket(); this.outSock.joinGroup(group.getAddress()); |