reliable multicast: periodically send acks

1 files changed, 10 insertions, 0 deletions

diff --git a/src/main/java/derms/net/rmulticast/HeartbeatMessage.java b/src/main/java/derms/net/rmulticast/HeartbeatMessage.java
new file mode 100644
index 0000000..a5a3c61
--- /dev/null
+++ b/src/main/java/derms/net/rmulticast/HeartbeatMessage.java
@@ -0,0 +1,10 @@
+package derms.net.rmulticast;
+
+import java.net.InetAddress;
+
+/** A message whose only purpose is to propagate acknowledgements and process IDs to the group. */
+class HeartbeatMessage extends Message<NullPayload> {
+    HeartbeatMessage(InetAddress sender, MessageID[] acks, MessageID[] nacks) {
+        super(new NullPayload(), sender, acks, nacks);
+    }
+}