diff --git a/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java index fe863d67e..19179ad55 100644 --- a/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java @@ -998,8 +998,8 @@ public class DefaultStringRedisConnection implements StringRedisConnection { } - public void sDiffStore(String destKey, String... keys) { - delegate.sDiffStore(serialize(destKey), serializeMulti(keys)); + public Long sDiffStore(String destKey, String... keys) { + return delegate.sDiffStore(serialize(destKey), serializeMulti(keys)); } @@ -1033,8 +1033,8 @@ public class DefaultStringRedisConnection implements StringRedisConnection { } - public void sInterStore(String destKey, String... keys) { - delegate.sInterStore(serialize(destKey), serializeMulti(keys)); + public Long sInterStore(String destKey, String... keys) { + return delegate.sInterStore(serialize(destKey), serializeMulti(keys)); } @@ -1106,8 +1106,8 @@ public class DefaultStringRedisConnection implements StringRedisConnection { } - public void sUnionStore(String destKey, String... keys) { - delegate.sUnionStore(serialize(destKey), serializeMulti(keys)); + public Long sUnionStore(String destKey, String... keys) { + return delegate.sUnionStore(serialize(destKey), serializeMulti(keys)); } diff --git a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java index f36ec121a..50c3f7b3c 100644 --- a/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java +++ b/src/main/java/org/springframework/data/redis/connection/StringRedisConnection.java @@ -173,15 +173,15 @@ public interface StringRedisConnection extends RedisConnection { Set sInter(String... keys); - void sInterStore(String destKey, String... keys); + Long sInterStore(String destKey, String... keys); Set sUnion(String... keys); - void sUnionStore(String destKey, String... keys); + Long sUnionStore(String destKey, String... keys); Set sDiff(String... keys); - void sDiffStore(String destKey, String... keys); + Long sDiffStore(String destKey, String... keys); Set sMembers(String key);