diff --git a/common/src/main/java/com/alibaba/nacos/common/remote/client/RpcClient.java b/common/src/main/java/com/alibaba/nacos/common/remote/client/RpcClient.java index 2d71b71b2..0bc70f452 100644 --- a/common/src/main/java/com/alibaba/nacos/common/remote/client/RpcClient.java +++ b/common/src/main/java/com/alibaba/nacos/common/remote/client/RpcClient.java @@ -455,7 +455,6 @@ public abstract class RpcClient implements Closeable { rpcClientStatus.set(RpcClientStatus.SHUTDOWN); LOGGER.info("Shutdown client event executor " + clientEventExecutor); clientEventExecutor.shutdownNow(); - LOGGER.info("Close current connection " + currentConnection.getConnectionId()); closeConnection(currentConnection); } @@ -587,6 +586,7 @@ public abstract class RpcClient implements Closeable { private void closeConnection(Connection connection) { if (connection != null) { + LOGGER.info("Close current connection " + connection.getConnectionId()); connection.close(); eventLinkedBlockingQueue.add(new ConnectionEvent(ConnectionEvent.DISCONNECTED)); }