Skip to content

Commit 39d7c37

Browse files
denglimingmp911de
authored andcommitted
Simplify CLUSTER MYID command for Jedis.
Closes #2226
1 parent b87ef55 commit 39d7c37

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterConnection.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@
7070
* @author Tao Chen
7171
* @author Chen Guanqun
7272
* @author Pavel Khokhlov
73+
* @author Liming Deng
7374
* @since 1.7
7475
*/
7576
public class JedisClusterConnection implements DefaultedRedisClusterConnection {
@@ -749,13 +750,10 @@ public Set<RedisClusterNode> clusterGetSlaves(RedisClusterNode master) {
749750
@Override
750751
public Map<RedisClusterNode, Collection<RedisClusterNode>> clusterGetMasterSlaveMap() {
751752

752-
List<NodeResult<Collection<RedisClusterNode>>> nodeResults = clusterCommandExecutor
753-
.executeCommandAsyncOnNodes((JedisClusterCommandCallback<Collection<RedisClusterNode>>) client -> {
754-
755-
// TODO: remove client.eval as soon as Jedis offers support for myid
756-
return JedisConverters.toSetOfRedisClusterNodes(
757-
client.clusterSlaves((String) client.eval("return redis.call('cluster', 'myid')", 0)));
758-
}, topologyProvider.getTopology().getActiveMasterNodes()).getResults();
753+
List<NodeResult<Collection<RedisClusterNode>>> nodeResults = clusterCommandExecutor.executeCommandAsyncOnNodes(
754+
(JedisClusterCommandCallback<Collection<RedisClusterNode>>) client -> JedisConverters
755+
.toSetOfRedisClusterNodes(client.clusterSlaves(client.clusterMyId())),
756+
topologyProvider.getTopology().getActiveMasterNodes()).getResults();
759757

760758
Map<RedisClusterNode, Collection<RedisClusterNode>> result = new LinkedHashMap<>();
761759

0 commit comments

Comments
 (0)