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

fuyou 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 086f9d130 remove invalid null check code (#6183)
086f9d130 is described below

commit 086f9d130ba7682533de7f449eabd4170071fa89
Author: hardyfish <[email protected]>
AuthorDate: Tue Feb 28 11:16:00 2023 +0800

    remove invalid null check code (#6183)
---
 .../src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java  | 2 --
 1 file changed, 2 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java 
b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index d901f7832..0521f1d99 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -897,7 +897,6 @@ public class MQClientAPIImpl implements 
NameServerUpdateCallback {
                         } else {
                             ackResult.setStatus(AckStatus.NO_EXIST);
                         }
-                        assert ackResult != null;
                         ackCallback.onSuccess(ackResult);
                     } catch (Exception e) {
                         ackCallback.onException(e);
@@ -943,7 +942,6 @@ public class MQClientAPIImpl implements 
NameServerUpdateCallback {
                         } else {
                             ackResult.setStatus(AckStatus.NO_EXIST);
                         }
-                        assert ackResult != null;
                         ackCallback.onSuccess(ackResult);
                     } catch (Exception e) {
                         ackCallback.onException(e);

Reply via email to