Class: Lapine::Consumer::Config

Inherits:
Object
  • Object
show all
Includes:
Mixlib::CLI
Defined in:
lib/lapine/consumer/config.rb

Instance Method Summary collapse

Instance Method Details

#connection_properties ⇒ Object 



105
106
107
108
109
110
111
112
113
114
115
 
# 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? ⇒ Boolean

Returns:

  • (Boolean) 


77
78
79
 
# File 'lib/lapine/consumer/config.rb', line 77

def debug?
  config[:debug]
end

#delete_queues ⇒ Object 



85
86
87
 
# File 'lib/lapine/consumer/config.rb', line 85

def delete_queues
  yaml_config['delete_queues'] || []
end

#load(argv) ⇒ Object 



72
73
74
75
 
# File 'lib/lapine/consumer/config.rb', line 72

def load(argv)
  parse_options argv
  self
end

#logfile ⇒ Object 



81
82
83
 
# File 'lib/lapine/consumer/config.rb', line 81

def logfile
  config[:logfile]
end

#queues ⇒ Object 



89
90
91
 
# File 'lib/lapine/consumer/config.rb', line 89

def queues
  yaml_config['queues'] || []
end

#require ⇒ Object 



93
94
95
 
# File 'lib/lapine/consumer/config.rb', line 93

def require
  yaml_config['require'] || []
end

#topics ⇒ Object 



97
98
99
 
# File 'lib/lapine/consumer/config.rb', line 97

def topics
  yaml_config['topics']
end

#transient? ⇒ Boolean

Returns:

  • (Boolean) 


101
102
103
 
# File 'lib/lapine/consumer/config.rb', line 101

def transient?
  config[:transient]
end