[broker] Ord instance of MessageId

src/Async/Worker/Broker/PGMQ.hs

@@ -43,7 +43,7 @@ instance (SerializableMessage a, Show a) => MessageBroker PGMQBroker a where
     deriving (Show)
   data Message PGMQBroker a = PGMQM a
   data MessageId PGMQBroker = PGMQMid Int
-    deriving (Eq, Show)
+    deriving (Eq, Show, Ord)
   data BrokerInitParams PGMQBroker a =
       PGMQBrokerInitParams PSQL.ConnectInfo PGMQ.VisibilityTimeout
     | PGMQBrokerInitConnStr BS.ByteString PGMQ.VisibilityTimeout

src/Async/Worker/Broker/Redis.hs

@@ -56,7 +56,7 @@ instance (SerializableMessage a, Show a) => MessageBroker RedisBroker a where
     deriving (Show)
   data Message RedisBroker a = RedisM a
   data MessageId RedisBroker = RedisMid Int
-    deriving (Eq, Show)
+    deriving (Eq, Show, Ord)
   data BrokerInitParams RedisBroker a = RedisBrokerInitParams Redis.ConnectInfo
 
   messageId (RedisBM (RedisWithMsgId { rmidId })) = RedisMid rmidId

src/Async/Worker/Broker/STM.hs

@@ -47,7 +47,7 @@ instance (Show a) => MessageBroker STMBroker a where
     deriving (Show)
   data Message STMBroker a = STMM a
   data MessageId STMBroker = STMMid Int
-    deriving (Eq, Show)
+    deriving (Eq, Show, Ord)
   data BrokerInitParams STMBroker a =
     STMBrokerInitParams { archiveMap :: TVar (Map.Map Queue (Map.Map Int (STMWithMsgId a)))
                         , stmMap :: TVar (Map.Map Queue (Map.Map Int (STMWithMsgId a))) }

src/Async/Worker/Broker/Types.hs

@@ -84,6 +84,7 @@ type SerializableMessage a = ( FromJSON a
 class (
         Eq (MessageId b)
       , Show (MessageId b)
+      , Ord (MessageId b)
       , ToJSON (MessageId b)
       , FromJSON (MessageId b)
       , Show (BrokerMessage b a)