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()));
                     }
                 }

Reply via email to