From 1badf2b447d31bebb97dd2af740dd20c7b3e8203 Mon Sep 17 00:00:00 2001 From: Nikita Date: Thu, 16 Jul 2015 15:17:00 +0300 Subject: [PATCH] HyperLogLog expiration support --- src/main/java/org/redisson/RedissonHyperLogLog.java | 4 ++-- src/main/java/org/redisson/core/RHyperLogLog.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/redisson/RedissonHyperLogLog.java b/src/main/java/org/redisson/RedissonHyperLogLog.java index dbfcc8139..b6127c4a5 100644 --- a/src/main/java/org/redisson/RedissonHyperLogLog.java +++ b/src/main/java/org/redisson/RedissonHyperLogLog.java @@ -26,7 +26,7 @@ import org.redisson.core.RHyperLogLog; import io.netty.util.concurrent.Future; -public class RedissonHyperLogLog extends RedissonObject implements RHyperLogLog { +public class RedissonHyperLogLog extends RedissonExpirable implements RHyperLogLog { protected RedissonHyperLogLog(ConnectionManager connectionManager, String name) { super(connectionManager, name); @@ -88,7 +88,7 @@ public class RedissonHyperLogLog extends RedissonObject implements RHyperLogL List args = new ArrayList(otherLogNames.length + 1); args.add(getName()); args.addAll(Arrays.asList(otherLogNames)); - return connectionManager.writeAsyncVoid(getName(), RedisCommands.PFMERGE, args.toArray()); + return connectionManager.writeAsync(getName(), RedisCommands.PFMERGE, args.toArray()); } } diff --git a/src/main/java/org/redisson/core/RHyperLogLog.java b/src/main/java/org/redisson/core/RHyperLogLog.java index 02ce86106..55de3cdeb 100644 --- a/src/main/java/org/redisson/core/RHyperLogLog.java +++ b/src/main/java/org/redisson/core/RHyperLogLog.java @@ -19,7 +19,7 @@ import io.netty.util.concurrent.Future; import java.util.Collection; -public interface RHyperLogLog extends RObject { +public interface RHyperLogLog extends RExpirable { boolean add(V obj);