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