diff options
Diffstat (limited to 'src/main/java/derms/net/rmulticast/Receive.java')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Receive.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/main/java/derms/net/rmulticast/Receive.java b/src/main/java/derms/net/rmulticast/Receive.java index f20f833..29ee305 100644 --- a/src/main/java/derms/net/rmulticast/Receive.java +++ b/src/main/java/derms/net/rmulticast/Receive.java @@ -50,12 +50,15 @@ class Receive<T extends Serializable & Hashable> implements Runnable { } private void receive(Message<T> msg) { + groupMembers.add(msg.sender); + + if (msg instanceof AnnounceMessage) + return; + acks.add(msg.id()); received.add(msg); delivered.add(msg); - groupMembers.add(msg.sender); - nacks.remove(msg.id()); retransmissions.remove(msg); |