diff --git a/src/main/java/org/springframework/data/redis/connection/srp/SrpConnection.java b/src/main/java/org/springframework/data/redis/connection/srp/SrpConnection.java index b53e59706..20d6b91c7 100644 --- a/src/main/java/org/springframework/data/redis/connection/srp/SrpConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/srp/SrpConnection.java @@ -179,6 +179,7 @@ public class SrpConnection implements RedisConnection { public List closePipeline() { if (pipeline != null) { + pipeline = null; List execute = new ArrayList(callback.complete()); callback.close(); callback = null;