diff --git a/lib/async/redis/cluster_client.rb b/lib/async/redis/cluster_client.rb
index 00ad22d..5732cc9 100644
--- a/lib/async/redis/cluster_client.rb
+++ b/lib/async/redis/cluster_client.rb
@@ -116,7 +116,7 @@ def reload_cluster!(endpoints = @endpoints)
 						
 						nodes = shard["nodes"].map do |node|
 							node = node.each_slice(2).to_h
-							endpoint = Endpoint.remote(node["ip"], node["port"])
+							endpoint = Endpoint.for(endpoint.scheme, node["endpoint"], port: node["port"])
 							
 							# Collect all endpoints:
 							endpoints << endpoint