From 2524ca668a4e80a05c8461fea6a565d3fd0b1cae Mon Sep 17 00:00:00 2001
From: meateggmilk <87265072+meateggmilk@users.noreply.github.com>
Date: Mon, 6 Dec 2021 23:49:51 +0800
Subject: [PATCH] fix query message bug (#49)

Co-authored-by: shizhili <shizhili@cmss.chinamobile.com>
---
 .../rocketmq/dashboard/service/impl/MessageServiceImpl.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 6c71bc2..6cb6432 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
@@ -329,7 +329,7 @@ public class MessageServiceImpl implements MessageService {
                         List<MessageExt> msgFoundList = pullResult.getMsgFoundList();
                         for (int i = msgFoundList.size() - 1; i >= 0; i--) {
                             MessageExt messageExt = msgFoundList.get(i);
-                            if (messageExt.getStoreTimestamp() < query.getBegin()) {
+                            if (messageExt.getStoreTimestamp() > query.getEnd()) {
                                 end--;
                             } else {
                                 hasIllegalOffset = false;