github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix ZPOPMIN\ZPOPMAX to count members error for all Spring Data Redis modules

Browse Source 
Signed-off-by: chenxiabin <czchenxiabin@gmail.com>
pull/5681/head
chenxiabin 12 months ago
parent 8b553c8e9b
commit adf3974e49
4 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File

8
redisson-spring-data/redisson-spring-data-27/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

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

8
redisson-spring-data/redisson-spring-data-30/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

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

8
redisson-spring-data/redisson-spring-data-31/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

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

8
redisson-spring-data/redisson-spring-data-32/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
Unescape Escape View File

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

Write Preview
Loading…
Cancel
Save