opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 10:54:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE 5265] Adjust nested logic to reduce nums of check in queryMsgByUniqKey (#5266)

Browse Source
This commit is contained in:
zhiliatom
2022-10-11 11:25:39 +08:00
committed by GitHub
parent 32c7d37f48
commit b944cd881b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
+2 -2
View File
@@ -454,8 +454,8 @@ public class MQAdminImpl {
}
//If namespace not null , reset Topic without namespace.
for (MessageExt messageExt : messageList) {
if (null != this.mQClientFactory.getClientConfig().getNamespace()) {
if (null != this.mQClientFactory.getClientConfig().getNamespace()) {
for (MessageExt messageExt : messageList) {
messageExt.setTopic(NamespaceUtil.withoutNamespace(messageExt.getTopic(), this.mQClientFactory.getClientConfig().getNamespace()));
}
}