Merge pull request #2657 from milowg/bug/MgetCommandSentToMaster

Fix Spring Data connector to set multiGet (MGET) commands to slave in…
pull/2664/head
Nikita Koksharov 5 years ago committed by GitHub
commit 6028464573
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -530,7 +530,7 @@ public class RedissonConnection extends AbstractRedisConnection {
@Override
public List<byte[]> mGet(byte[]... keys) {
return write(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
return read(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
}
@Override

@ -560,7 +560,7 @@ public class RedissonConnection extends AbstractRedisConnection {
@Override
public List<byte[]> mGet(byte[]... keys) {
return write(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
return read(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
}
@Override

@ -576,7 +576,7 @@ public class RedissonConnection extends AbstractRedisConnection {
@Override
public List<byte[]> mGet(byte[]... keys) {
return write(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
return read(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
}
@Override

@ -543,7 +543,7 @@ public class RedissonConnection extends AbstractRedisConnection {
@Override
public List<byte[]> mGet(byte[]... keys) {
return write(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
return read(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
}
private static final RedisCommand<Boolean> SET = new RedisCommand<Boolean>("SET", new BooleanReplayConvertor());

@ -573,7 +573,7 @@ public class RedissonConnection extends AbstractRedisConnection {
@Override
public List<byte[]> mGet(byte[]... keys) {
return write(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
return read(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
}
private static final RedisCommand<Boolean> SET = new RedisCommand<Boolean>("SET", new BooleanReplayConvertor());

@ -565,7 +565,7 @@ public class RedissonConnection extends AbstractRedisConnection {
@Override
public List<byte[]> mGet(byte[]... keys) {
return write(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
return read(keys[0], ByteArrayCodec.INSTANCE, MGET, Arrays.asList(keys).toArray());
}
private static final RedisCommand<Boolean> SET = new RedisCommand<Boolean>("SET", new BooleanReplayConvertor());

Loading…
Cancel
Save