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 8c9da13b40..5dcc346ef5 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 @@ -581,7 +581,7 @@ public class NettyRemotingClient extends NettyRemotingAbstract implements Remoti } } else { this.closeChannel(addr, channel); - throw new RemotingConnectException(addr); + throw new RemotingConnectException(channelRemoteAddr); } }