opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 05:44:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

update double validations

Browse Source
This commit is contained in:
tigerweili
2022-07-08 23:55:27 +08:00
parent dbc3972498
commit 6596df8d72
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
+1 -1
View File
@@ -86,7 +86,7 @@ public class BrokerOuterAPI {
public String fetchNameServerAddr() {
try {
String addrs = this.topAddressing.fetchNSAddr();
if (addrs != null && !UtilAll.isBlank(addrs)) {
if (!UtilAll.isBlank(addrs)) {
if (!addrs.equals(this.nameSrvAddr)) {
log.info("name server address changed, old: {} new: {}", this.nameSrvAddr, addrs);
this.updateNameServerAddressList(addrs);
client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+1 -1
View File
@@ -227,7 +227,7 @@ public class MQClientAPIImpl {
public String fetchNameServerAddr() {
try {
String addrs = this.topAddressing.fetchNSAddr();
if (addrs != null && !UtilAll.isBlank(addrs)) {
if (!UtilAll.isBlank(addrs)) {
if (!addrs.equals(this.nameSrvAddr)) {
log.info("name server address changed, old=" + this.nameSrvAddr + ", new=" + addrs);
this.updateNameServerAddressList(addrs);