Module: Msgr

Defined in:
lib/msgr.rb,
lib/msgr/pool.rb,
lib/msgr/route.rb,
lib/msgr/client.rb,
lib/msgr/errors.rb,
lib/msgr/routes.rb,
lib/msgr/binding.rb,
lib/msgr/logging.rb,
lib/msgr/message.rb,
lib/msgr/railtie.rb,
lib/msgr/version.rb,
lib/msgr/consumer.rb,
lib/msgr/connection.rb,
lib/msgr/dispatcher.rb,
lib/msgr/message/acknowledge.rb

Defined Under Namespace

Modules: Logging, VERSION Classes: Binding, CausedByError, Client, Connection, ConnectionError, Consumer, Dispatcher, Message, Pool, Railtie, Route, Routes

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.client ⇒ Object 



35
36
37
 
# File 'lib/msgr.rb', line 35

def client
  @client ||= Msgr::Client.new config
end

.config ⇒ Object 



31
32
33
 
# File 'lib/msgr.rb', line 31

def config
  @config ||= {}
end

Class Method Details

.after_load(&block) ⇒ Object 



52
53
54
55
 
# File 'lib/msgr.rb', line 52

def after_load(&block)
  @after_load_callbacks ||= []
  @after_load_callbacks << block
end

.logger ⇒ Object 



39
40
41
42
43
44
45
46
 
# File 'lib/msgr.rb', line 39

def logger
  if @logger.nil?
    @logger = Logger.new $stdout
    @logger.level = Logger::Severity::INFO
  end

  @logger
end

.logger=(logger) ⇒ Object 



48
49
50
 
# File 'lib/msgr.rb', line 48

def logger=(logger)
  @logger = logger
end

.start ⇒ Object 



57
58
59
60
61
62
63
 
# File 'lib/msgr.rb', line 57

def start
  client.start
  (@after_load_callbacks || []).each do |callback|
    callback.call client
  end
  client
end