Fix Spring Data connector to set multiGet (MGET) commands to slave instead of master when configured to do so #2656

Signed-off-by: Gil Milow <milowg@users.noreply.github.com>
pull/2657/head
Gil Milow 5 years ago
parent 6cd9b28d9c
commit 6ae0839359

@ -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