diff --git a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java index e39c628bb..64c07b817 100644 --- a/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java @@ -1321,7 +1321,7 @@ public class LettuceConnection implements RedisConnection { public Long zCount(byte[] key, double min, double max) { try { - if (isQueueing()) { + if (isPipelined()) { pipeline(asyncConn.zcount(key, min, max)); return null; } @@ -1347,7 +1347,7 @@ public class LettuceConnection implements RedisConnection { ZStoreArgs storeArgs = LettuceUtils.zArgs(aggregate, weights); try { - if (isQueueing()) { + if (isPipelined()) { pipeline(asyncConn.zinterstore(destKey, storeArgs, sets)); return null; } @@ -1360,7 +1360,7 @@ public class LettuceConnection implements RedisConnection { public Long zInterStore(byte[] destKey, byte[]... sets) { try { - if (isQueueing()) { + if (isPipelined()) { pipeline(asyncConn.zinterstore(destKey, sets)); return null; } diff --git a/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionPipelineIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionPipelineIntegrationTests.java index 4369646cf..b5c339a2b 100644 --- a/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionPipelineIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionPipelineIntegrationTests.java @@ -65,18 +65,6 @@ public class LettuceConnectionPipelineIntegrationTests extends public void testUnwatch() throws Exception { } - @Ignore("DATAREDIS-140 Lettuce zCount/zInterStore methods execute synchronously when pipelining") - public void testZInterStoreAggWeights() { - } - - @Ignore("DATAREDIS-140 Lettuce zCount/zInterStore methods execute synchronously when pipelining") - public void testZInterStore() { - } - - @Ignore("DATAREDIS-140 Lettuce zCount/zInterStore methods execute synchronously when pipelining") - public void testZCount() { - } - // Overrides, usually due to return values being Long vs Boolean or Set vs // List