diff --git a/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java b/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java index 2bd4f5ac9..5ea876118 100644 --- a/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java +++ b/redisson/src/main/java/org/redisson/connection/MasterSlaveEntry.java @@ -502,6 +502,9 @@ public class MasterSlaveEntry { } public RFuture connectionReadOp(RedisCommand command, RedisClient client) { + if (config.getReadMode() == ReadMode.MASTER) { + return connectionWriteOp(command); + } return slaveBalancer.getConnection(command, client); }