(rocketmq) branch develop updated: [ISSUE #10291] fix queryMessage default index type (#10292)

[yx9o]

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

yx9o 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 c625406648 [ISSUE #10291] fix queryMessage default index type (#10292)
c625406648 is described below

commit c6254066487b376687ba8cd959d46aedd6a2c40e
Author: yuz10 <845238...@qq.com>
AuthorDate: Sat May 16 00:16:44 2026 +0800

    [ISSUE #10291] fix queryMessage default index type (#10292)
    
    * [ISSUE #10110] Plain request process success and response fail when 
tlsMode=enforcing
    
    * fix queryMessage default indexType
    
    * fix
---
 client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 b6fd72ad01..729e917eed 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
@@ -320,7 +320,7 @@ public class MQAdminImpl {
 
     public QueryResult queryMessage(String clusterName, String topic, String 
key, int maxNum, long begin, long end, boolean isUniqKey) throws 
MQClientException,
         InterruptedException {
-        return queryMessage(clusterName, topic, key, maxNum, begin, end, 
isUniqKey, null, null);
+        return queryMessage(clusterName, topic, key, maxNum, begin, end, 
isUniqKey, isUniqKey ? MessageConst.INDEX_UNIQUE_TYPE : 
MessageConst.INDEX_KEY_TYPE, null);
     }
 
     public QueryResult queryMessage(String clusterName, String topic, String 
key, int maxNum, long begin, long end, boolean isUniqKey, String indexType, 
String lastKey) throws MQClientException,