rename

apache · Sep 23, 2024 · 71eb691 · 71eb691
1 parent 2e92f33
commit 71eb691
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
@@ -520,11 +520,11 @@ public void updateNameServerAddressList(List<String> addrs) {
                 this.namesrvAddrList.set(addrs);
 
                 // should close the channel if choosed addr is not exist.
-                String choseNameServerAddr = this.namesrvAddrChoosed.get();
-                if (choseNameServerAddr != null && !addrs.contains(choseNameServerAddr)) {
-                    namesrvAddrChoosed.compareAndSet(choseNameServerAddr, null);
+                String chosenNameServerAddr = this.namesrvAddrChoosed.get();
+                if (chosenNameServerAddr != null && !addrs.contains(chosenNameServerAddr)) {
+                    namesrvAddrChoosed.compareAndSet(chosenNameServerAddr, null);
                     for (String addr : this.channelTables.keySet()) {
-                        if (addr.contains(choseNameServerAddr)) {
+                        if (addr.contains(chosenNameServerAddr)) {
                             ChannelWrapper channelWrapper = this.channelTables.get(addr);
                             if (channelWrapper != null) {
                                 channelWrapper.close();