File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -66,7 +66,7 @@ def ==(other)
66
66
# @since 2.0.0
67
67
def add ( host )
68
68
address = Address . new ( host )
69
- unless addresses . include? ( address ) || ( @topology . single? && address . seed != @topology . seed )
69
+ if ! addresses . include? ( address ) || direct_connection? ( address )
70
70
log_debug ( [ "Adding #{ address . to_s } to the cluster." ] )
71
71
addresses . push ( address )
72
72
server = Server . new ( address , event_listeners ,
@@ -201,5 +201,11 @@ def self.create(client)
201
201
cluster = Cluster . new ( client . cluster . addresses . map ( &:to_s ) , client . options )
202
202
client . instance_variable_set ( :@cluster , cluster )
203
203
end
204
+
205
+ private
206
+
207
+ def direct_connection? ( address )
208
+ @topology . single? && address . seed == @topology . seed
209
+ end
204
210
end
205
211
end
You can’t perform that action at this time.
0 commit comments