Fixed - Redis scan cursor exceed Long.MAX_VALUE in AWS Elasticache #5517

pull/5564/head
Nikita Koksharov 1 year ago
parent bf9b4c1e4c
commit 91bd4bba2a

@ -68,7 +68,7 @@ public class RedissonKeysRx {
private RedisClient client;
private List<String> firstValues;
private String nextIterPos;
private String nextIterPos = "0";
private long currentIndex;

@ -50,7 +50,7 @@ public class RedissonMapRxIterator<K, V, M> {
ReplayProcessor<M> p = ReplayProcessor.create();
return p.doOnRequest(new LongConsumer() {
private String nextIterPos;
private String nextIterPos = "0";
private RedisClient client;
private AtomicLong elementsRead = new AtomicLong();

@ -36,7 +36,7 @@ public abstract class SetRxIterator<V> {
ReplayProcessor<V> p = ReplayProcessor.create();
return p.doOnRequest(new LongConsumer() {
private String nextIterPos;
private String nextIterPos = "0";
private RedisClient client;
private AtomicLong elementsRead = new AtomicLong();

Loading…
Cancel
Save