class Lapine::Consumer::Config
Public Instance Methods
connection_properties()
click to toggle source
# File lib/lapine/consumer/config.rb, line 105 def connection_properties { host: '127.0.0.1', port: 5672, ssl: false, vhost: '/', username: 'guest', password: 'guest' }.merge(file_connection_props) .merge(cli_connection_props) end
debug?()
click to toggle source
# File lib/lapine/consumer/config.rb, line 77 def debug? config[:debug] end
delete_queues()
click to toggle source
# File lib/lapine/consumer/config.rb, line 85 def delete_queues yaml_config['delete_queues'] || [] end
load(argv)
click to toggle source
# File lib/lapine/consumer/config.rb, line 72 def load(argv) parse_options argv self end
logfile()
click to toggle source
# File lib/lapine/consumer/config.rb, line 81 def logfile config[:logfile] end
queues()
click to toggle source
# File lib/lapine/consumer/config.rb, line 89 def queues yaml_config['queues'] || [] end
require()
click to toggle source
# File lib/lapine/consumer/config.rb, line 93 def require yaml_config['require'] || [] end
topics()
click to toggle source
# File lib/lapine/consumer/config.rb, line 97 def topics yaml_config['topics'] end
transient?()
click to toggle source
# File lib/lapine/consumer/config.rb, line 101 def transient? config[:transient] end
Private Instance Methods
cli_connection_props()
click to toggle source
# File lib/lapine/consumer/config.rb, line 124 def cli_connection_props { host: config[:host], port: config[:port] ? config[:port].to_i : nil, ssl: config[:ssl], vhost: config[:vhost], username: config[:username], password: config[:password] }.delete_if { |k, v| v.nil? } end
file_connection_props()
click to toggle source
# File lib/lapine/consumer/config.rb, line 119 def file_connection_props return {} unless yaml_config['connection'] yaml_config['connection'].inject({}){|memo,(k,v)| memo[k.to_sym] = v; memo} end
yaml_config()
click to toggle source
# File lib/lapine/consumer/config.rb, line 135 def yaml_config @yaml ||= YAML.load_file(config[:config_file]) end