Ensure closing connection in Pipeline (#3865)

sazzad16 · sazzad16 · commit 287d743427d4 · 2024-07-11T13:11:44.000+06:00
even if there is an error in sync method.
diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java
@@ -10,6 +10,7 @@
 import redis.clients.jedis.exceptions.JedisDataException;
 import redis.clients.jedis.graph.GraphCommandObjects;
 import redis.clients.jedis.params.*;
+import redis.clients.jedis.util.IOUtils;
 import redis.clients.jedis.util.KeyValue;
 
 public class Pipeline extends PipelineBase implements DatabasePipelineCommands, Closeable {
@@ -46,10 +47,12 @@ public final <T> Response<T> appendCommand(CommandObject<T> commandObject) {
 
   @Override
   public void close() {
-    sync();
-
-    if (closeConnection) {
-      connection.close();
+    try {
+      sync();
+    } finally {
+      if (closeConnection) {
+        IOUtils.closeQuietly(connection);
+      }
     }
   }
 
