class URI::AMQP

Constants

COMPONENT
DEFAULT_PORT
VERSION

Attributes

cacertfile[R]
certfile[R]
channel_max[R]
connection_timeout[R]
fail_if_no_peer_cert[R]
heartbeat[R]
keyfile[R]
verify[R]
vhost[R]

Public Class Methods

new(*arg) click to toggle source
Calls superclass method
# File lib/uri/amqp.rb, line 20
def initialize(*arg)
  super(*arg)

  parse_path
  parse_query
end

Public Instance Methods

cacertfile=(value) click to toggle source
# File lib/uri/amqp.rb, line 56
def cacertfile=(value)
  check_cacertfile(value)
  set_cacertfile(value)
end
certfile=(value) click to toggle source
# File lib/uri/amqp.rb, line 61
def certfile=(value)
  check_certfile(value)
  set_certfile(value)
end
channel_max=(value) click to toggle source
# File lib/uri/amqp.rb, line 42
def channel_max=(value)
  set_channel_max(value)
end
connection_timeout=(value) click to toggle source
# File lib/uri/amqp.rb, line 38
def connection_timeout=(value)
  set_connection_timeout(value)
end
fail_if_no_peer_cert=(value) click to toggle source
# File lib/uri/amqp.rb, line 51
def fail_if_no_peer_cert=(value)
  check_fail_if_no_peer_cert(value)
  set_fail_if_no_peer_cert(value)
end
heartbeat=(value) click to toggle source
# File lib/uri/amqp.rb, line 34
def heartbeat=(value)
  set_heartbeat(value)
end
hierarchical?() click to toggle source

URI::AMQP doesn't have path

# File lib/uri/amqp.rb, line 72
def hierarchical?
  false
end
keyfile=(value) click to toggle source
# File lib/uri/amqp.rb, line 66
def keyfile=(value)
  check_keyfile(value)
  set_keyfile(value)
end
verify=(value) click to toggle source
# File lib/uri/amqp.rb, line 46
def verify=(value)
  check_verify(value)
  set_verify(value)
end
vhost=(value) click to toggle source
# File lib/uri/amqp.rb, line 29
def vhost=(value)
  check_vhost(value)
  set_vhost(value)
end

Protected Instance Methods

set_cacertfile(value) click to toggle source
# File lib/uri/amqp.rb, line 116
def set_cacertfile(value)
  @cacertfile = value
end
set_certfile(value) click to toggle source
# File lib/uri/amqp.rb, line 120
def set_certfile(value)
  @certfile = value
end
set_channel_max(value) click to toggle source
# File lib/uri/amqp.rb, line 104
def set_channel_max(value)
  @channel_max = value&.to_i
end
set_connection_timeout(value) click to toggle source
# File lib/uri/amqp.rb, line 100
def set_connection_timeout(value)
  @connection_timeout = value&.to_i
end
set_fail_if_no_peer_cert(value) click to toggle source
# File lib/uri/amqp.rb, line 112
def set_fail_if_no_peer_cert(value)
  @fail_if_no_peer_cert = !value.nil?
end
set_heartbeat(value) click to toggle source
# File lib/uri/amqp.rb, line 96
def set_heartbeat(value)
  @heartbeat = value&.to_i
end
set_host(value) click to toggle source
Calls superclass method
# File lib/uri/amqp.rb, line 88
def set_host(value)
  super(value && CGI.unescape(value))
end
set_keyfile(value) click to toggle source
# File lib/uri/amqp.rb, line 124
def set_keyfile(value)
  @keyfile = value
end
set_user(value) click to toggle source
Calls superclass method
# File lib/uri/amqp.rb, line 84
def set_user(value)
  super(value && CGI.unescape(value))
end
set_userinfo(user, password = nil) click to toggle source
Calls superclass method
# File lib/uri/amqp.rb, line 78
def set_userinfo(user, password = nil)
  user &&= CGI.unescape(user)
  password &&= CGI.unescape(password)
  super(user, password)
end
set_verify(value) click to toggle source
# File lib/uri/amqp.rb, line 108
def set_verify(value)
  @verify = !value.nil?
end
set_vhost(value) click to toggle source
# File lib/uri/amqp.rb, line 92
def set_vhost(value)
  @vhost = value && CGI.unescape(value.delete('/'))
end

Private Instance Methods

check_vhost(value) click to toggle source
# File lib/uri/amqp.rb, line 152
def check_vhost(value)
  raise InvalidComponentError, "bad vhost (expected only leading \"/\"): #{value}" if value && value !~ %r{^/[^/]*$}
end
parse_path() click to toggle source
# File lib/uri/amqp.rb, line 130
def parse_path
  return if path.empty?

  self.vhost = @path.dup
end
parse_query() click to toggle source
# File lib/uri/amqp.rb, line 136
def parse_query
  return if @query.nil?

  # CONSIDER: CGI::parse(@query)
  params = Hash[@query.scan(/(.+?)=([^&]+)&*/)]

  self.heartbeat = params["heartbeat"]
  self.connection_timeout = params["connection_timeout"]
  self.channel_max = params["channel_max"]
  self.verify = params["verify"]
  self.fail_if_no_peer_cert = params["fail_if_no_peer_cert"]
  self.cacertfile = params["cacertfile"]
  self.certfile = params["certfile"]
  self.keyfile = params["keyfile"]
end