[rocketmq] branch develop updated: [ISSUE #6917] fix cannot query all messages of the same msgId

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new fd4a397a1 [ISSUE #6917] fix cannot query all messages of the same msgId
fd4a397a1 is described below

commit fd4a397a14349a81a63ecdfea48499444565e134
Author: yuz10 <845238...@qq.com>
AuthorDate: Fri Jun 23 11:31:40 2023 +0800

    [ISSUE #6917] fix cannot query all messages of the same msgId
    
    Co-authored-by: y00421926 <yuzh...@huawei.com>
---
 .../java/org/apache/rocketmq/client/impl/MQAdminImpl.java  | 14 +-------------
 1 file changed, 1 insertion(+), 13 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java 
b/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
index e002f7a5e..33fc44fd6 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
@@ -410,19 +410,7 @@ public class MQAdminImpl {
                     for (MessageExt msgExt : qr.getMessageList()) {
                         if (isUniqKey) {
                             if (msgExt.getMsgId().equals(key)) {
-
-                                if (messageList.size() > 0) {
-
-                                    if (messageList.get(0).getStoreTimestamp() 
> msgExt.getStoreTimestamp()) {
-
-                                        messageList.clear();
-                                        messageList.add(msgExt);
-                                    }
-
-                                } else {
-
-                                    messageList.add(msgExt);
-                                }
+                                messageList.add(msgExt);
                             } else {
                                 log.warn("queryMessage by uniqKey, find 
message key not matched, maybe hash duplicate {}", msgExt.toString());
                             }