summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net/rmulticast/Receive.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/net/rmulticast/Receive.java')
-rw-r--r--src/main/java/derms/net/rmulticast/Receive.java7
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);