reliable multicast: announce presence to group

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