Skip to content

Commit 32aaf45

Browse files
authored
Use the given protocol to connect to sentinels (for auth or other purposes). (#48)
1 parent a363147 commit 32aaf45

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/async/redis/sentinels.rb

+2-2
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ def resolve_address
5050

5151
def resolve_master
5252
@sentinel_endpoints.each do |sentinel_endpoint|
53-
client = Client.new(sentinel_endpoint)
53+
client = Client.new(sentinel_endpoint, protocol: @protocol)
5454

5555
begin
5656
address = client.call('sentinel', 'get-master-addr-by-name', @master_name)
@@ -66,7 +66,7 @@ def resolve_master
6666

6767
def resolve_slave
6868
@sentinel_endpoints.each do |sentinel_endpoint|
69-
client = Client.new(sentinel_endpoint)
69+
client = Client.new(sentinel_endpoint, protocol: @protocol)
7070

7171
begin
7272
reply = client.call('sentinel', 'slaves', @master_name)

0 commit comments

Comments
 (0)