diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkIterable.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkIterable.java
deleted file mode 100644
index 152f36ce2..000000000
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkIterable.java
+++ /dev/null
@@ -1,59 +0,0 @@
-/*
- * Copyright 2011 the original author or authors.
- * 
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.springframework.data.keyvalue.redis.core;
-
-import java.util.Iterator;
-import java.util.List;
-
-/**
- * Wrapper class allowing for stream-like access across a list of values.
- * 
- * @author Costin Leau
- */
-class BulkIterable<T> implements Iterable<T> {
-
-	private final List<T> list;
-	private volatile int index = 0;
-
-	public BulkIterable(List<T> list) {
-		this.list = list;
-	}
-
-	public boolean hasMore() {
-		throw new UnsupportedOperationException();
-	}
-
-	@Override
-	public Iterator<T> iterator() {
-		return new Iterator<T>() {
-
-			@Override
-			public boolean hasNext() {
-				return index < list.size();
-			}
-
-			@Override
-			public T next() {
-				return list.get(index++);
-			}
-
-			@Override
-			public void remove() {
-				throw new UnsupportedOperationException();
-			}
-		};
-	}
-}
diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkMapper.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkMapper.java
index d1388b062..30048a241 100644
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkMapper.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/BulkMapper.java
@@ -21,11 +21,11 @@ import java.util.Iterator;
  * Mapper translating Redis bulk value responses (typically returned by a sort query) to actual objects. Implementations of this interface do not have to worry
  * about exception or connection handling.
  * <p/>
- * Typically used by {@link RedisTemplate} <tt>sortAndGet</tt> methods.
+ * Typically used by {@link RedisTemplate} <tt>sort</tt> methods.
  * 
  * @author Costin Leau
  */
-public interface BulkMapper<T> {
+public interface BulkMapper<T, V> {
 
-	T mapBulk(Iterator<byte[]> valueStream);
+	T mapBulk(Iterator<V> valueStream);
 }
diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisOperations.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisOperations.java
index a95cb1bd4..f9c4411c3 100644
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisOperations.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisOperations.java
@@ -196,8 +196,9 @@ public interface RedisOperations<K, V> {
 	<T> List<T> sort(SortQuery<K> query, RedisSerializer<T> resultSerializer);
 
 
-	<T> List<T> sort(SortQuery<K> query, BulkMapper<T> bulkMapper);
+	<T> List<T> sort(SortQuery<K> query, BulkMapper<T, V> bulkMapper);
 
+	<T, S> List<T> sort(SortQuery<K> query, BulkMapper<T, S> bulkMapper, RedisSerializer<S> resultSerializer);
 
 	Long sort(SortQuery<K> query, K storeKey);
 }
\ No newline at end of file
diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java
index 2ddfab695..f2e04732e 100644
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/RedisTemplate.java
@@ -1950,28 +1950,26 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
 		return (List<T>) deserializeValues(vals, List.class, resultSerializer);
 	}
 
+	@SuppressWarnings("unchecked")
 	@Override
-	public <T> List<T> sort(SortQuery<K> query, BulkMapper<T> bulkMapper) {
-		final byte[] rawKey = rawKey(query.getKey());
-		final SortParameters params = convertQuery(query, stringSerializer);
+	public <T> List<T> sort(SortQuery<K> query, BulkMapper<T, V> bulkMapper) {
+		return sort(query, bulkMapper, valueSerializer);
+	}
 
-		List<byte[]> vals = execute(new RedisCallback<List<byte[]>>() {
-			@Override
-			public List<byte[]> doInRedis(RedisConnection connection) throws DataAccessException {
-				return connection.sort(rawKey, params);
-			}
-		}, true);
+	@Override
+	public <T, S> List<T> sort(SortQuery<K> query, BulkMapper<T, S> bulkMapper, RedisSerializer<S> resultSerializer) {
+		List<S> values = sort(query, resultSerializer);
 
 		int bulkSize = query.getGetPattern().size();
-		List<T> result = new ArrayList<T>(vals.size() / bulkSize + 1);
+		List<T> result = new ArrayList<T>(values.size() / bulkSize + 1);
 
-		final List<byte[]> bulk = new ArrayList<byte[]>(bulkSize);
-		final List<byte[]> listView = Collections.unmodifiableList(bulk);
+		final List<S> bulk = new ArrayList<S>(bulkSize);
+		final List<S> listView = Collections.unmodifiableList(bulk);
 
-		for (byte[] bs : vals) {
-			bulk.add(bs);
+		for (S s : values) {
+			bulk.add(s);
 			if (bulk.size() == bulkSize) {
-				bulkMapper.mapBulk(listView.iterator());
+				result.add(bulkMapper.mapBulk(listView.iterator()));
 				bulk.clear();
 			}
 		}
diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/query/DefaultSortQuery.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/query/DefaultSortQuery.java
index b07a75206..4348e2fa2 100644
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/query/DefaultSortQuery.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/core/query/DefaultSortQuery.java
@@ -72,4 +72,12 @@ class DefaultSortQuery<K> implements SortQuery<K> {
 	public List<String> getGetPattern() {
 		return gets;
 	}
+
+	@Override
+	public String toString() {
+		return "DefaultSortQuery [alpha=" + alpha + ", by=" + by + ", gets=" + gets + ", key=" + key + ", limit="
+				+ limit + ", order=" + order + "]";
+	}
+
+
 }
\ No newline at end of file