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