HyperLogLog expiration support

pull/243/head
Nikita 10 years ago
parent 2b168cb0fa
commit 1badf2b447

@ -26,7 +26,7 @@ import org.redisson.core.RHyperLogLog;
import io.netty.util.concurrent.Future;
public class RedissonHyperLogLog<V> extends RedissonObject implements RHyperLogLog<V> {
public class RedissonHyperLogLog<V> extends RedissonExpirable implements RHyperLogLog<V> {
protected RedissonHyperLogLog(ConnectionManager connectionManager, String name) {
super(connectionManager, name);
@ -88,7 +88,7 @@ public class RedissonHyperLogLog<V> extends RedissonObject implements RHyperLogL
List<Object> args = new ArrayList<Object>(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());
}
}

@ -19,7 +19,7 @@ import io.netty.util.concurrent.Future;
import java.util.Collection;
public interface RHyperLogLog<V> extends RObject {
public interface RHyperLogLog<V> extends RExpirable {
boolean add(V obj);

Loading…
Cancel
Save