fix: check RedisConnection status befor RedisConnection object join freeConnections

Signed-off-by: xujie <mikawudi@qq.com>
pull/2956/head
xujie 5 years ago
parent 48f081ed53
commit eb243e3f39

@ -151,6 +151,10 @@ public class ClientConnectionsEntry {
}
public void releaseConnection(RedisConnection connection) {
if (connection.isClosed()) {
return;
}
if (client != connection.getRedisClient()) {
connection.closeAsync();
return;
@ -225,6 +229,10 @@ public class ClientConnectionsEntry {
}
public void releaseSubscribeConnection(RedisPubSubConnection connection) {
if (connection.isClosed()) {
return;
}
if (client != connection.getRedisClient()) {
connection.closeAsync();
return;

Loading…
Cancel
Save