Fix pipeline in JedisConnection

2011-02-04 15:34:49 -05:00
parent 2a431091fb
commit 0098e7b02f
1 changed files with 1 additions and 0 deletions
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java
@@ -1664,6 +1664,7 @@ public class JedisConnection implements RedisConnection {
 					redis.clients.jedis.ZParams.Aggregate.valueOf(aggregate.name()));
 			if (isPipelined()) {
 				pipeline.zinterstore(destKey, zparams, sets);
+				return null;
 			}
 			return jedis.zinterstore(destKey, zparams, sets);
 		} catch (Exception ex) {