diff --git a/src/main/java/redis/clients/jedis/Connection.java b/src/main/java/redis/clients/jedis/Connection.java index 8c0425c8f9..86450fa640 100644 --- a/src/main/java/redis/clients/jedis/Connection.java +++ b/src/main/java/redis/clients/jedis/Connection.java @@ -234,10 +234,10 @@ public void disconnect() { outputStream.flush(); socket.close(); } catch (IOException ex) { - broken = true; throw new JedisConnectionException(ex); } finally { IOUtils.closeQuietly(socket); + setBroken(); } } }