Module: Legion::Transport

Defined in:
lib/legion/transport.rb,
lib/legion/transport/local.rb,
lib/legion/transport/queue.rb,
lib/legion/transport/spool.rb,
lib/legion/transport/common.rb,
lib/legion/transport/message.rb,
lib/legion/transport/version.rb,
lib/legion/transport/consumer.rb,
lib/legion/transport/exchange.rb,
lib/legion/transport/settings.rb,
lib/legion/transport/connection.rb,
lib/legion/transport/queues/node.rb,
lib/legion/transport/queues/agent.rb,
lib/legion/transport/exchanges/lex.rb,
lib/legion/transport/messages/task.rb,
lib/legion/transport/connection/ssl.rb,
lib/legion/transport/exchanges/node.rb,
lib/legion/transport/exchanges/task.rb,
lib/legion/transport/exchanges/agent.rb,
lib/legion/transport/exchanges/crypt.rb,
lib/legion/transport/queues/task_log.rb,
lib/legion/transport/connection/vault.rb,
lib/legion/transport/messages/subtask.rb,
lib/legion/transport/messages/task_log.rb,
lib/legion/transport/queues/node_crypt.rb,
lib/legion/transport/queues/node_status.rb,
lib/legion/transport/queues/task_update.rb,
lib/legion/transport/exchanges/extensions.rb,
lib/legion/transport/messages/task_update.rb,
lib/legion/transport/messages/lex_register.rb,
lib/legion/transport/messages/check_subtask.rb

Defined Under Namespace

Modules: Common, Connection, Exchanges, Local, Messages, Queues, Settings, Spool Classes: Consumer, Exchange, Message, Queue

Constant Summary collapse

TYPE = 
'bunny'
CONNECTOR = 
::Bunny
VERSION = 
'1.2.5'

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/legion/transport.rb', line 14

def logger
  return @logger unless @logger.nil?

  require 'logger'
  @logger = ::Logger.new($stdout)
  configured_level = begin
    Legion::Settings[:transport][:logger_level]
  rescue StandardError
    'warn'
  end
  @logger.level = case configured_level.to_s
                  when 'debug' then ::Logger::DEBUG
                  when 'info'  then ::Logger::INFO
                  when 'error' then ::Logger::ERROR
                  when 'fatal' then ::Logger::FATAL
                  else              ::Logger::WARN
                  end
  @logger
end

.settings ⇒ Object 



34
35
36
37
38
 
# File 'lib/legion/transport.rb', line 34

def settings
  Legion::Settings[:transport] if Legion.const_defined? 'Settings'

  Legion::Transport::Settings.default
end