From fa44da26fad27b5e710601b96d4780079c53b53c Mon Sep 17 00:00:00 2001
From: Costin Leau <cleau@vmware.com>
Date: Wed, 23 May 2012 20:37:43 +0300
Subject: [PATCH] ZSetOps#removeRange* return the # of elements removed

DATAREDIS-86
---
 .../data/redis/core/DefaultZSetOperations.java | 18 ++++++++----------
 .../data/redis/core/ZSetOperations.java        |  4 ++--
 2 files changed, 10 insertions(+), 12 deletions(-)

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<K, V> extends AbstractOperations<K, V> 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<Object>() {
+		return execute(new RedisCallback<Long>() {
 			
-			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<Object>() {
+		return execute(new RedisCallback<Long>() {
 			
-			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<K, V> {
 
 	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);