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