fix ZPOPMIN\ZPOPMAX to count members error

Signed-off-by: chenxiabin <czchenxiabin@gmail.com>
pull/5681/head
chenxiabin 1 year ago
parent a4f0c9479d
commit 8b553c8e9b

@ -2485,11 +2485,13 @@ public class RedissonConnection extends AbstractRedisConnection {
return write(key, ByteArrayCodec.INSTANCE, ZPOPMIN, (Object) key);
}
private static final RedisCommand<Set<Tuple>> ZPOPMIN_FOR_SET = new RedisCommand<>("ZPOPMIN", new ScoredSortedSetReplayDecoder());
@Override
public Set<Tuple> zPopMin(byte[] key, long count) {
Assert.notNull(key, "Key must not be null!");
return write(key, ByteArrayCodec.INSTANCE, ZPOPMIN, key, count);
return write(key, ByteArrayCodec.INSTANCE, ZPOPMIN_FOR_SET, key, count);
}
private static final RedisCommand<Tuple> BZPOPMIN = new RedisCommand<>("BZPOPMIN", new ScoredSortedSingleBlockingReplayDecoder());
@ -2511,11 +2513,13 @@ public class RedissonConnection extends AbstractRedisConnection {
return write(key, ByteArrayCodec.INSTANCE, ZPOPMAX, (Object) key);
}
private static final RedisCommand<Set<Tuple>> ZPOPMAX_FOR_SET = new RedisCommand<>("ZPOPMAX", new ScoredSortedSetReplayDecoder());
@Override
public Set<Tuple> zPopMax(byte[] key, long count) {
Assert.notNull(key, "Key must not be null!");
return write(key, ByteArrayCodec.INSTANCE, ZPOPMAX, key, count);
return write(key, ByteArrayCodec.INSTANCE, ZPOPMAX_FOR_SET, key, count);
}
private static final RedisCommand<Tuple> BZPOPMAX = new RedisCommand<>("BZPOPMAX", new ScoredSortedSingleBlockingReplayDecoder());

Loading…
Cancel
Save