From 6e9f8d667e64abbad950bd000fd78bef7db0003b Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 23 May 2018 12:49:09 +0300 Subject: [PATCH] refactoring --- .../main/java/org/redisson/connection/MasterSlaveEntry.java | 3 +++ 1 file changed, 3 insertions(+) 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); }