From 6e2049c8c5054fdfe5feed79454f8cdf3b457285 Mon Sep 17 00:00:00 2001
From: Big Roc <onlybigroc@gmail.com>
Date: Mon, 21 Apr 2025 18:19:54 +0800
Subject: [PATCH] [ISSUES #213 #191] messageViews storeTimestamp sort desc

---
 .../dashboard/service/impl/MessageServiceImpl.java       | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java b/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
index 16d0d4e9..173fc696 100644
--- a/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
+++ b/src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
@@ -389,6 +389,7 @@ private MessagePageTask queryFirstMessagePage(MessageQueryByPage query) {
 
                 }
             }
+            messageViewsSort(messageViews);
             PageImpl<MessageView> page = new PageImpl<>(messageViews, query.page(), total);
             return new MessagePageTask(page, queueOffsetInfos);
         } catch (Exception e) {
@@ -458,6 +459,7 @@ private Page<MessageView> queryMessageByTaskPage(MessageQueryByPage query, List<
 
                 }
             }
+            messageViewsSort(messageViews);
             return new PageImpl<>(messageViews, query.page(), total);
         } catch (Exception e) {
             Throwables.throwIfUnchecked(e);
@@ -551,4 +553,11 @@ public DefaultMQPullConsumer buildDefaultMQPullConsumer(RPCHook rpcHook, boolean
         consumer.setUseTLS(useTLS);
         return consumer;
     }
+    private static void messageViewsSort(List<MessageView> messageViews) {
+        messageViews.sort((o1, o2) -> {
+            long time1 = o1.getStoreTimestamp();
+            long time2 = o2.getStoreTimestamp();
+            return Long.compare(time2, time1); // desc
+        });
+    }
 }