Module: Mafia

Defined in:
lib/mafia.rb,
lib/mafia/dealer.rb,
lib/mafia/logger.rb,
lib/mafia/consumer.rb,
lib/mafia/consumer_pool.rb,
lib/mafia/default_consumer.rb

Defined Under Namespace

Modules: Consumer, Logger Classes: ConsumerPool, Dealer, DefaultConsumer

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



26
27
28
 
# File 'lib/mafia.rb', line 26

def self.config
  @config ||= {}
end

.config_to_url(config) ⇒ Object 



38
39
40
41
42
43
44
45
 
# 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 = {}) ⇒ Object 



22
23
24
 
# File 'lib/mafia.rb', line 22

def self.configure(c={})
  @config = config.merge(c)
end

.consumers ⇒ Object 



18
19
20
 
# File 'lib/mafia.rb', line 18

def self.consumers
  @consumers ||= []
end

.log_level ⇒ Object 



34
35
36
 
# File 'lib/mafia.rb', line 34

def self.log_level
  @config[:log_level] || ::Logger::INFO
end

.logger ⇒ Object 



30
31
32
 
# File 'lib/mafia.rb', line 30

def self.logger
  Mafia::Logger.logger
end

.register_consumer(consumer) ⇒ Object 



14
15
16
 
# File 'lib/mafia.rb', line 14

def self.register_consumer(consumer)
  self.consumers << consumer
end