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