diff options
Diffstat (limited to 'src/main/java/derms/net/rmulticast/ReliableMulticast.java')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/ReliableMulticast.java | 7 |
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 { |