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 20d6b91c7..86a112486 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 @@ -1354,7 +1354,7 @@ public class SrpConnection implements RedisConnection { public Long zCount(byte[] key, double min, double max) { try { - if (isQueueing()) { + if (isPipelined()) { pipeline(pipeline.zcount(key, min, max)); return null; } @@ -1395,7 +1395,7 @@ public class SrpConnection implements RedisConnection { } try { - if (isQueueing()) { + if (isPipelined()) { pipeline(pipeline.zinterstore(args)); return null; } diff --git a/src/test/java/org/springframework/data/redis/connection/srp/SrpConnectionPipelineIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/srp/SrpConnectionPipelineIntegrationTests.java index d1907b45a..6944e86f0 100644 --- a/src/test/java/org/springframework/data/redis/connection/srp/SrpConnectionPipelineIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/srp/SrpConnectionPipelineIntegrationTests.java @@ -82,14 +82,6 @@ public class SrpConnectionPipelineIntegrationTests extends public void testGetConfig() { } - @Ignore("DATAREDIS-142 SRP zCount/zInterStore methods execute synchronously when pipelining") - public void testZCount() { - } - - @Ignore("DATAREDIS-142 SRP zCount/zInterStore methods execute synchronously when pipelining") - public void testZInterStore() { - } - @Ignore("DATAREDIS-152 Syntax error on zRangeByScore and and zRangeByScoreWithScores when using offset and count") public void testZRangeByScoreOffsetCount() { }