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