Class: AMQ::URI

Inherits:
Object
  • Object
show all
Defined in:
lib/amq/uri.rb

Constant Summary collapse

DEFAULTS = 
{
  heartbeat: nil,
  connection_timeout: nil,
  channel_max: nil,
  auth_mechanism: [],
  verify: false,
  fail_if_no_peer_cert: false,
  cacertfile: nil,
  certfile: nil,
  keyfile: nil
}.freeze

Class Method Summary collapse

Class Method Details

.parse(connection_string) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/amq/uri.rb', line 32

def self.parse(connection_string)
  uri = ::URI.parse(connection_string)
  unless %w{amqp amqps}.include?(uri.scheme)
    raise ArgumentError, "Connection URI must use amqp or amqps schema (example: amqp://bus.megacorp.internal:5766), learn more at http://bit.ly/ks8MXK"
  end

  opts = DEFAULTS.dup

  opts[:scheme] = uri.scheme
  opts[:user]   = ::CGI::unescape(uri.user) if uri.user
  opts[:pass]   = ::CGI::unescape(uri.password) if uri.password
  opts[:host]   = uri.host if uri.host and uri.host != ""
  opts[:port]   = uri.port || AMQP_DEFAULT_PORTS[uri.scheme]
  opts[:ssl]    = uri.scheme.to_s.downcase =~ /amqps/i # TODO: rename to tls
  if uri.path =~ %r{^/(.*)}
    if $1.index('/')
      raise ArgumentError, "#{uri} has multiple-segment path; please percent-encode any slashes in the vhost name (e.g. /production => %2Fproduction). Learn more at http://bit.ly/amqp-gem-and-connection-uris"
    end
    opts[:vhost] = ::CGI::unescape($1)
  end

  if uri.query
    query_params = Hash.new { |hash, key| hash[key] = [] }
    ::URI.decode_www_form(uri.query).each do |key, value|
      query_params[key] << value
    end
    query_params.each do |key, value|
      query_params[key] = value.one? ? value.first : value
    end
    query_params.default = nil

    opts[:heartbeat] = query_params["heartbeat"].to_i
    opts[:connection_timeout] = query_params["connection_timeout"].to_i
    opts[:channel_max] = query_params["channel_max"].to_i
    opts[:auth_mechanism] = query_params["auth_mechanism"]

    %w(cacertfile certfile keyfile).each do |tls_option|
      if query_params[tls_option] && uri.scheme == "amqp"
        raise ArgumentError, "The option '#{tls_option}' can only be used in URIs that use amqps schema"
      else
        opts[tls_option.to_sym] = query_params[tls_option]
      end
    end

    %w(verify fail_if_no_peer_cert).each do |tls_option|
      if query_params[tls_option] && uri.scheme == "amqp"
        raise ArgumentError, "The option '#{tls_option}' can only be used in URIs that use amqps schema"
      else
        opts[tls_option.to_sym] = as_boolean(query_params[tls_option])
      end
    end
  end

  opts
end

.parse_amqp_url(s) ⇒ Object 



88
89
90
 
# File 'lib/amq/uri.rb', line 88

def self.parse_amqp_url(s)
  parse(s)
end