From 0098e7b02f41b7c375c8716c1c6ec1ad768c4a3f Mon Sep 17 00:00:00 2001 From: ddelautre Date: Fri, 4 Feb 2011 15:34:49 -0500 Subject: [PATCH] Fix pipeline in JedisConnection --- .../data/keyvalue/redis/connection/jedis/JedisConnection.java | 1 + 1 file changed, 1 insertion(+) diff --git 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 index d45227d12..37085d4fa 100644 --- 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) {