diff --git a/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java b/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java index 6fe4a33af..0d6d9dc4e 100644 --- a/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/rjc/RjcConnection.java @@ -1670,16 +1670,14 @@ public class RjcConnection implements RedisConnection { public Set zRevRangeWithScores(byte[] key, long start, long end) { String stringKey = RjcUtils.decode(key); - String minString = Long.toString(start); - String maxString = Long.toString(end); try { if (isPipelined()) { - pipeline.zrevrangeByScoreWithScores(stringKey, minString, maxString); + pipeline.zrevrangeWithScores(stringKey, (int) start, (int) end); return null; } - return RjcUtils.convertElementScore(session.zrevrangeByScoreWithScores(stringKey, minString, maxString)); + return RjcUtils.convertElementScore(session.zrevrangeWithScores(stringKey, (int) start, (int) end)); } catch (Exception ex) { throw convertRjcAccessException(ex); } diff --git a/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionIntegrationTests.java index b697f369a..39c26b88f 100644 --- a/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionIntegrationTests.java @@ -104,10 +104,6 @@ public class RjcConnectionIntegrationTests extends AbstractConnectionIntegration public void testPubSubWithPatterns() { } - @Ignore("DATAREDIS-137 zRevRangeWithScores returns incorrect results") - public void testZRevRangeWithScores() { - } - @Ignore("DATAREDIS-148 Syntax error on RJC zUnionStore") public void testZUnionStoreAggWeights() { } diff --git a/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionPipelineIntegrationTests.java b/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionPipelineIntegrationTests.java index 1b498d141..7d7a143db 100644 --- a/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionPipelineIntegrationTests.java +++ b/src/test/java/org/springframework/data/redis/connection/rjc/RjcConnectionPipelineIntegrationTests.java @@ -85,10 +85,6 @@ public class RjcConnectionPipelineIntegrationTests extends public void testStrLen() { } - @Ignore("DATAREDIS-137 zRevRangeWithScores returns incorrect results") - public void testZRevRangeWithScores() { - } - @Ignore("DATAREDIS-148 Syntax error on RJC zUnionStore") public void testZUnionStoreAggWeights() { }