reliable multicast: announce presence to group

1 files changed, 7 insertions, 0 deletions

diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
index 528bb41..a9e1fa4 100644
--- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java
+++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
@@ -53,6 +53,13 @@ public class ReliableMulticast<T extends Serializable & Hashable> {
         (new Thread(new Retransmit<T>(retransmissions, outSock, group))).start();
 
         (new Thread(new Prune<T>(received, groupMembers))).start();
+
+        try {
+            (new Thread(new Announce(group, laddr, outSock))).start();
+        } catch (IOException e) {
+            log.severe("Failed to start announce thread: " + e.getMessage());
+            throw e;
+        }
     }
 
     public void send(T payload) throws IOException {