diff options
Diffstat (limited to 'src/main/java/derms/net/rmulticast/ReliableMulticast.java')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/ReliableMulticast.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java index 2ead37e..72b3019 100644 --- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java +++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java @@ -61,9 +61,9 @@ public class ReliableMulticast<T extends MessagePayload> { (new Thread(new Prune<T>(received, groupMembers))).start(); try { - (new Thread(new Announce(group, laddr, outSock))).start(); + (new Thread(new Heartbeat(group, laddr, acks, nacks, outSock))).start(); } catch (IOException e) { - log.severe("Failed to start announce thread: " + e.getMessage()); + log.severe("Failed to start heartbeat thread: " + e.getMessage()); throw e; } } |