From 4aedf160eab3b61c97e7b835e4d0eb4de16087cc Mon Sep 17 00:00:00 2001 From: yiqi <1455432762@qq.com> Date: Sat, 4 Jan 2025 14:48:32 +0800 Subject: [PATCH] remove redundant get --- .../apache/rocketmq/remoting/netty/NettyRemotingClient.java | 5 ----- 1 file changed, 5 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 index 6ac54aed6d2..06c87843882 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java @@ -624,11 +624,6 @@ private ChannelFuture getAndCreateChannelAsync(final String addr) throws Interru return getAndCreateNameserverChannelAsync(); } - ChannelWrapper cw = this.channelTables.get(addr); - if (cw != null && cw.isOK()) { - return cw.getChannelFuture(); - } - return this.createChannelAsync(addr); }