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 8c9da13b40b..5dcc346ef52 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 RemotingCommand invokeSync(String addr, final RemotingCommand request, lo } } else { this.closeChannel(addr, channel); - throw new RemotingConnectException(addr); + throw new RemotingConnectException(channelRemoteAddr); } }