1 files changed, 6 insertions, 1 deletions
diff --git a/src/main/java/derms/net/tomulticast/Message.java b/src/main/java/derms/net/tomulticast/Message.java
index 035e968..29d1ff7 100644
--- a/src/main/java/derms/net/tomulticast/Message.java
+++ b/src/main/java/derms/net/tomulticast/Message.java
@@ -2,7 +2,7 @@ package derms.net.tomulticast;
 
 import derms.net.rmulticast.MessagePayload;
 
-class Message<T extends MessagePayload> implements MessagePayload {
+class Message<T extends MessagePayload> implements MessagePayload, Comparable<Message<T>> {
     long seq; // Sequence number.
     T payload;
 
@@ -34,6 +34,11 @@ class Message<T extends MessagePayload> implements MessagePayload {
     }
 
     @Override
+    public int compareTo(Message<T> other) {
+        return Long.compare(this.seq, other.seq);
+    }
+
+    @Override
     public String toString() {
         return getClass().getSimpleName() + "{" + seq + ", " + payload + "}";
     }