diff --git a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java index ccd926bcd..4d45a535c 100644 --- a/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java @@ -1661,7 +1661,7 @@ public class JedisConnection implements RedisConnection { transaction.zcount(key, min, max); return null; } - if (isQueueing()) { + if (isPipelined()) { pipeline.zcount(key, min, max); return null; } @@ -1715,7 +1715,7 @@ public class JedisConnection implements RedisConnection { transaction.zinterstore(destKey, sets); return null; } - if (isQueueing()) { + if (isPipelined()) { pipeline.zinterstore(destKey, sets); return null; }