You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by st...@apache.org on 2021/12/06 15:49:56 UTC
[rocketmq-dashboard] branch master updated: fix query message bug (#49)
This is an automated email from the ASF dual-hosted git repository.
styletang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git
The following commit(s) were added to refs/heads/master by this push:
new 2524ca6 fix query message bug (#49)
2524ca6 is described below
commit 2524ca668a4e80a05c8461fea6a565d3fd0b1cae
Author: meateggmilk <87...@users.noreply.github.com>
AuthorDate: Mon Dec 6 23:49:51 2021 +0800
fix query message bug (#49)
Co-authored-by: shizhili <sh...@cmss.chinamobile.com>
---
.../org/apache/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;