diff --git a/lib/async/redis/sentinels.rb b/lib/async/redis/sentinels.rb index 30ec901..575a95b 100644 --- a/lib/async/redis/sentinels.rb +++ b/lib/async/redis/sentinels.rb @@ -50,7 +50,7 @@ def resolve_address def resolve_master @sentinel_endpoints.each do |sentinel_endpoint| - client = Client.new(sentinel_endpoint) + client = Client.new(sentinel_endpoint, protocol: @protocol) begin address = client.call('sentinel', 'get-master-addr-by-name', @master_name) @@ -66,7 +66,7 @@ def resolve_master def resolve_slave @sentinel_endpoints.each do |sentinel_endpoint| - client = Client.new(sentinel_endpoint) + client = Client.new(sentinel_endpoint, protocol: @protocol) begin reply = client.call('sentinel', 'slaves', @master_name)