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 ddd99b28e4b7e5ffa232f44231a43716ce1acdc0..c8ca8e791e13103892738f9bc92bb6098abb51fa 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); }