From 50f0035fd980305faf666fdcd2d3afe2411ce56e Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sat, 16 Nov 2024 16:47:24 -0500
Subject: TotalOrderMulticastReceiver

---
 src/main/java/derms/net/tomulticast/Message.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

(limited to 'src/main/java/derms/net/tomulticast/Message.java')

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;
 
@@ -33,6 +33,11 @@ class Message<T extends MessagePayload> implements MessagePayload {
         return other.seq == this.seq && other.hash() == this.hash();
     }
 
+    @Override
+    public int compareTo(Message<T> other) {
+        return Long.compare(this.seq, other.seq);
+    }
+
     @Override
     public String toString() {
         return getClass().getSimpleName() + "{" + seq + ", " + payload + "}";
-- 
cgit v1.2.3