[rocketmq] branch develop updated: Add else handle for notification

[zhouxzhan]

This is an automated email from the ASF dual-hosted git repository.

zhouxzhan 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 31a7edd61 Add else handle for notification
31a7edd61 is described below

commit 31a7edd618d70c62ad2bdfcda187c16ff7cfd37e
Author: zhouxiang <zhouxiang....@alibaba-inc.com>
AuthorDate: Thu Dec 1 16:13:58 2022 +0800

    Add else handle for notification
---
 .../org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
index f0c04bcc9..ec81e815c 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
@@ -607,8 +607,9 @@ public class MQClientAPIExt extends MQClientAPIImpl {
                         } catch (Throwable t) {
                             future.completeExceptionally(t);
                         }
+                    } else {
+                        future.completeExceptionally(new 
MQBrokerException(response.getCode(), response.getRemark()));
                     }
-                    future.completeExceptionally(new 
MQBrokerException(response.getCode(), response.getRemark()));
                 } else {
                     
future.completeExceptionally(processNullResponseErr(responseFuture));
                 }