module Mafia
Public Class Methods
config()
click to toggle source
# File lib/mafia.rb, line 26 def self.config @config ||= {} end
config_to_url(config)
click to toggle source
# File lib/mafia.rb, line 38 def self.config_to_url(config) user = config[:username] password = config[:password] host = config[:host] port = config[:port] vhost = config[:vhost] "amqp://#{user}:#{password}@#{host}:#{port}#{vhost}" end
configure(c={})
click to toggle source
# File lib/mafia.rb, line 22 def self.configure(c={}) @config = config.merge(c) end
consumers()
click to toggle source
# File lib/mafia.rb, line 18 def self.consumers @consumers ||= [] end
log_level()
click to toggle source
# File lib/mafia.rb, line 34 def self.log_level @config[:log_level] || ::Logger::INFO end
logger()
click to toggle source
# File lib/mafia.rb, line 30 def self.logger Mafia::Logger.logger end
register_consumer(consumer)
click to toggle source
# File lib/mafia.rb, line 14 def self.register_consumer(consumer) self.consumers << consumer end