Method: NATS#process_uri_options

Defined in:
lib/nats/client.rb

#process_uri_options ⇒ Object

Parse out URIs which can now be an array of server choices The server pool will contain both explicit and implicit members.



1322
1323
1324
1325
1326
1327
1328
 
# File 'lib/nats/client.rb', line 1322

def process_uri_options #:nodoc
  @server_pool = []
  uri = options[:uris] || options[:servers] || options[:uri]
  uri = uri.kind_of?(Array) ? uri : [uri]
  uri.each { |u| server_pool << { :uri => u.is_a?(URI) ? u.dup : URI.parse(u) } }
  bind_primary
end