mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
[ISSUE #2735] QueryMsgByUniqueKey tool should return all messages with same unique key
This commit is contained in:
@@ -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);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user