Skip to content

Commit a40d400

Browse files
committed
Broadcast read-only commands to all nodes
1 parent 91bb8b1 commit a40d400

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/main/java/redis/clients/jedis/executors/ClusterCommandExecutor.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,13 @@ public void close() {
4545

4646
@Override
4747
public final <T> T broadcastCommand(CommandObject<T> commandObject) {
48-
Map<String, ConnectionPool> connectionMap = provider.getPrimaryNodesConnectionMap();
48+
Map<String, ConnectionPool> connectionMap;
49+
50+
if (commandObject.getFlags().contains(CommandObject.CommandFlag.READONLY)) {
51+
connectionMap = provider.getConnectionMap();
52+
} else {
53+
connectionMap = provider.getPrimaryNodesConnectionMap();
54+
}
4955

5056
boolean isErrored = false;
5157
T reply = null;

0 commit comments

Comments
 (0)