From 672f581953673e4e47ef7153677937ddbe50e6c4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=96=9C=E9=98=B3?= <terrance.lzm@alibaba-inc.com>
Date: Mon, 24 May 2021 23:11:14 +0800
Subject: [PATCH] [ISSUE #2735] QueryMsgByUniqueKey tool should return all
 messages with same unique key

---
 .../apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
index ddd99b28..c8ca8e79 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
@@ -998,8 +998,8 @@ public class DefaultMQAdminExtImpl implements MQAdminExt, MQAdminExtInner {
     }
 
     public QueryResult queryMessageByUniqKey(String topic, String key, int maxNum, long begin,
-                                    long end) throws MQClientException,
-            InterruptedException {
+        long end) throws MQClientException, InterruptedException {
+
         return this.mqClientInstance.getMQAdminImpl().queryMessageByUniqKey(topic, key, maxNum, begin, end);
     }
 
-- 
GitLab