This is an automated email from the ASF dual-hosted git repository.
lizhanhui 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 b944cd881 [ISSUE 5265] Adjust nested logic to reduce nums of check in
queryMsgByUniqKey (#5266)
b944cd881 is described below
commit b944cd881b26c0a612fbb05c0b00a19f740bb0db
Author: zhiliatom <[email protected]>
AuthorDate: Tue Oct 11 11:25:39 2022 +0800
[ISSUE 5265] Adjust nested logic to reduce nums of check in
queryMsgByUniqKey (#5266)
---
client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 385278594..44e5b7204 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
@@ -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()));
}
}