jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-11 03:49:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix query message bug (#49)

Browse Source 
Co-authored-by: shizhili <shizhili@cmss.chinamobile.com>
This commit is contained in:
meateggmilk
2021-12-06 23:49:51 +08:00
committed by GitHub
parent 6054c057c8
commit 2524ca668a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/apache/rocketmq/dashboard/service/impl/MessageServiceImpl.java
View File

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