diff --git a/src/main/java/org/springframework/data/redis/core/DefaultZSetOperations.java b/src/main/java/org/springframework/data/redis/core/DefaultZSetOperations.java index bb20ff4ad..79382b4f2 100644 --- a/src/main/java/org/springframework/data/redis/core/DefaultZSetOperations.java +++ b/src/main/java/org/springframework/data/redis/core/DefaultZSetOperations.java @@ -232,25 +232,23 @@ class DefaultZSetOperations extends AbstractOperations implements ZS } - public void removeRange(K key, final long start, final long end) { + public Long removeRange(K key, final long start, final long end) { final byte[] rawKey = rawKey(key); - execute(new RedisCallback() { + return execute(new RedisCallback() { - public Object doInRedis(RedisConnection connection) { - connection.zRemRange(rawKey, start, end); - return null; + public Long doInRedis(RedisConnection connection) { + return connection.zRemRange(rawKey, start, end); } }, true); } - public void removeRangeByScore(K key, final double min, final double max) { + public Long removeRangeByScore(K key, final double min, final double max) { final byte[] rawKey = rawKey(key); - execute(new RedisCallback() { + return execute(new RedisCallback() { - public Object doInRedis(RedisConnection connection) { - connection.zRemRangeByScore(rawKey, min, max); - return null; + public Long doInRedis(RedisConnection connection) { + return connection.zRemRangeByScore(rawKey, min, max); } }, true); } diff --git a/src/main/java/org/springframework/data/redis/core/ZSetOperations.java b/src/main/java/org/springframework/data/redis/core/ZSetOperations.java index 42ef3aa45..4014e4c9e 100644 --- a/src/main/java/org/springframework/data/redis/core/ZSetOperations.java +++ b/src/main/java/org/springframework/data/redis/core/ZSetOperations.java @@ -71,9 +71,9 @@ public interface ZSetOperations { Boolean remove(K key, Object o); - void removeRange(K key, long start, long end); + Long removeRange(K key, long start, long end); - void removeRangeByScore(K key, double min, double max); + Long removeRangeByScore(K key, double min, double max); Long count(K key, double min, double max);