diff options
| -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) { |