diff --git a/src/main/java/com/github/sttk/sabi_redis/RedisDataSrc.java b/src/main/java/com/github/sttk/sabi_redis/RedisDataSrc.java index e834e29..6c86135 100644 --- a/src/main/java/com/github/sttk/sabi_redis/RedisDataSrc.java +++ b/src/main/java/com/github/sttk/sabi_redis/RedisDataSrc.java @@ -197,6 +197,7 @@ public RedisClient create() throws Err { } try (var conn = client.connect()) { } catch (Exception e) { + client.shutdown(); var redisURL = RedisURI.create(this.uri); throw new Err(new FailToConnectToRedis(this.cr, redisURL), e); } @@ -224,6 +225,7 @@ public RedisClient create() throws Err { } try (var conn = client.connect()) { } catch (Exception e) { + client.shutdown(); throw new Err(new FailToConnectToRedis(this.cr, this.redisURI), e); } return client;