Do not close connection by url when connection closed. (sofastack#498)

krisjin · Feb 20, 2019 · adf9544 · adf9544
1 parent 83833b6
commit adf9544
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ng-bolt/src/main/java/com/alipay/sofa/rpc/transport/bolt/BoltClientConnectionManager.java b/...ng-bolt/src/main/java/com/alipay/sofa/rpc/transport/bolt/BoltClientConnectionManager.java
@@ -126,7 +126,7 @@ public Connection getConnection(RpcClient rpcClient, ClientTransportConfig trans
                 if (LOGGER.isWarnEnabled()) {
                     LOGGER.warn("Multiple threads init ClientTransport with same key:" + url);
                 }
-                connection.close(); //如果同时有人插入，则使用第一个
+                rpcClient.closeStandaloneConnection(connection); //如果同时有人插入，则使用第一个
                 connection = oldConnection;
             } else {
 
@@ -188,7 +188,7 @@ public void closeConnection(RpcClient rpcClient, ClientTransportConfig transport
             }
         }
         if (needDestroy) {
-            rpcClient.closeConnection(url);
+            rpcClient.closeStandaloneConnection(connection);
         }
     }
 }