DATAREDIS-500 - Use Hash Key and Hash Value serializers in RedisTemplate executePipelined(…).

RedisTemplate executePipelined(RedisCallback) uses now the Hash Key and Hash Value serializers to deserialize the response.

Original pull request: #190.
CLA: 174020160421053943 (Anqing Shao).

Author: argszero

src/main/java/org/springframework/data/redis/core/RedisTemplate.java

@@ -273,7 +273,7 @@ public List<Object> doInRedis(RedisConnection connection) throws DataAccessExcep
 					}
 					List<Object> closePipeline = connection.closePipeline();
 					pipelinedClosed = true;
-					return deserializeMixedResults(closePipeline, resultSerializer, resultSerializer, resultSerializer);
+					return deserializeMixedResults(closePipeline, resultSerializer, hashKeySerializer, hashValueSerializer);
 				} finally {
 					if (!pipelinedClosed) {
 						connection.closePipeline();

src/test/java/org/springframework/data/redis/core/RedisTemplateTests.java

@@ -49,6 +49,7 @@
 import org.springframework.data.redis.connection.DataType;
 import org.springframework.data.redis.connection.RedisConnection;
 import org.springframework.data.redis.connection.StringRedisConnection;
+import org.springframework.data.redis.connection.jedis.JedisClusterConnection;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 import org.springframework.data.redis.connection.jredis.JredisConnectionFactory;
 import org.springframework.data.redis.connection.srp.SrpConnectionFactory;
@@ -305,6 +306,22 @@ public Object doInRedis(RedisConnection connection) throws DataAccessException {
 		assertEquals(Arrays.asList(new Object[] { 5l, 1l, 2l, Arrays.asList(new Long[] { 10l, 11l }) }), results);
 	}
 
+	@Test
+	public void testExecutePipelinedWidthDifferentHashKeySerializerAndHashValueSerializer() {
+		assumeTrue(redisTemplate instanceof StringRedisTemplate);
+		redisTemplate.setKeySerializer(new StringRedisSerializer());
+		redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+		redisTemplate.setHashValueSerializer(new GenericToStringSerializer<Long>(Long.class));
+		redisTemplate.opsForHash().put((K) "foo", "key", 1L);
+		List<Object> results = redisTemplate.executePipelined(new RedisCallback() {
+			public Object doInRedis(RedisConnection connection) throws DataAccessException {
+				connection.hGetAll(((StringRedisSerializer) redisTemplate.getKeySerializer()).serialize("foo"));
+				return null;
+			}
+		});
+		assertEquals(((Map) results.get(0)).get("key"), 1L);
+	}
+
 	@Test(expected = InvalidDataAccessApiUsageException.class)
 	public void testExecutePipelinedNonNullRedisCallback() {
 		redisTemplate.executePipelined(new RedisCallback<String>() {