diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-12-02 18:02:35 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-12-02 18:02:35 -0500 |
| commit | e59e38ab6036b70ce307a5936b59aa239a7e7922 (patch) | |
| tree | 1c3cf6ce9be1eafa63a11621d18e33b170c22cd6 /src | |
| parent | 92c8eae71fd662c2b7e76b17309c1b2f91c38d41 (diff) | |
| download | soen423-e59e38ab6036b70ce307a5936b59aa239a7e7922.zip | |
rmulticast: make HeartbeatMessage Serializable
Diffstat (limited to 'src')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Heartbeat.java | 1 | ||||
| -rw-r--r-- | src/main/java/derms/net/rmulticast/MessageID.java | 4 |
2 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/derms/net/rmulticast/Heartbeat.java b/src/main/java/derms/net/rmulticast/Heartbeat.java index 5dac49d..30e8d42 100644 --- a/src/main/java/derms/net/rmulticast/Heartbeat.java +++ b/src/main/java/derms/net/rmulticast/Heartbeat.java @@ -57,6 +57,7 @@ class Heartbeat implements Runnable { nacks.toArray(new MessageID[0])); ByteBuffer buf = Serial.encode(msg); sock.send(buf, group); + log.info("Sent " + msg); acks.clear(); } } diff --git a/src/main/java/derms/net/rmulticast/MessageID.java b/src/main/java/derms/net/rmulticast/MessageID.java index 70680b2..c760b53 100644 --- a/src/main/java/derms/net/rmulticast/MessageID.java +++ b/src/main/java/derms/net/rmulticast/MessageID.java @@ -1,6 +1,8 @@ package derms.net.rmulticast; -class MessageID { +import java.io.Serializable; + +class MessageID implements Serializable { int id; MessageID(int id) { |