File tree Expand file tree Collapse file tree 1 file changed +5
-7
lines changed
src/main/java/org/springframework/data/redis/connection/jedis Expand file tree Collapse file tree 1 file changed +5
-7
lines changed Original file line number Diff line number Diff line change 7070 * @author Tao Chen
7171 * @author Chen Guanqun
7272 * @author Pavel Khokhlov
73+ * @author Liming Deng
7374 * @since 1.7
7475 */
7576public 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
You can’t perform that action at this time.
0 commit comments