Class: Mcrain::Rabbitmq
- Inherits:
-
Base
- Object
- Base
- Mcrain::Rabbitmq
show all
- Defined in:
- lib/mcrain/rabbitmq.rb
Instance Attribute Summary
Attributes inherited from Base
#skip_reset_after_teardown
Instance Method Summary
collapse
Methods inherited from Base
#initialize, #logger, #reset, #setup, #start, #start_callback, #stop_or_kill_and_remove, #teardown, #wait, #wait_port, work_dir
#build_client, #client, #client_instantiation_script, #client_script
#add_volume_options, #container, #container_image, #find_portno, #host, included, #info, #ip, #name, #port, #ssh_uri
Constructor Details
This class inherits a constructor from Mcrain::Base
Instance Method Details
#build_docker_options ⇒ Object
12
13
14
15
16
|
# File 'lib/mcrain/rabbitmq.rb', line 12
def build_docker_options
r = super
r['HostConfig']['PortBindings']["5672/tcp"] = [{ 'HostPort' => runtime_port.to_s }]
return r
end
|
#client_class ⇒ Object
41
42
43
|
# File 'lib/mcrain/rabbitmq.rb', line 41
def client_class
RabbitMQ::HTTP::Client
end
|
#client_init_args ⇒ Object
45
46
47
|
# File 'lib/mcrain/rabbitmq.rb', line 45
def client_init_args
["http://#{host}:#{port}", {username: username, password: password}]
end
|
#client_require ⇒ Object
37
38
39
|
# File 'lib/mcrain/rabbitmq.rb', line 37
def client_require
'rabbitmq/http/client'
end
|
#password ⇒ Object
33
34
35
|
# File 'lib/mcrain/rabbitmq.rb', line 33
def password
"guest"
end
|
#runtime_port ⇒ Object
18
19
20
|
# File 'lib/mcrain/rabbitmq.rb', line 18
def runtime_port
@runtime_port ||= find_portno
end
|
#runtime_url ⇒ Object
26
27
28
|
# File 'lib/mcrain/rabbitmq.rb', line 26
def runtime_url
"rabbitmq://#{host}:#{runtime_port}"
end
|
#url ⇒ Object
22
23
24
|
# File 'lib/mcrain/rabbitmq.rb', line 22
def url
"http://#{username}:#{password}@#{host}:#{port}"
end
|
#username ⇒ Object
30
31
32
|
# File 'lib/mcrain/rabbitmq.rb', line 30
def username
"guest"
end
|
#wait_for_ready ⇒ Object
49
50
51
|
# File 'lib/mcrain/rabbitmq.rb', line 49
def wait_for_ready
client.list_users
end
|