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/errors.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/helpers/pool.rb,
lib/legion/transport/queues/agent.rb,
lib/legion/transport/tenant_quota.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/helpers/policy.rb,
lib/legion/transport/exchanges/agent.rb,
lib/legion/transport/exchanges/crypt.rb,
lib/legion/transport/queues/task_log.rb,
lib/legion/transport/tenant_topology.rb,
lib/legion/transport/connection/vault.rb,
lib/legion/transport/messages/subtask.rb,
lib/legion/transport/exchanges/logging.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/tenant_provisioner.rb,
lib/legion/transport/exchanges/extensions.rb,
lib/legion/transport/helpers/channel_pool.rb,
lib/legion/transport/messages/task_update.rb,
lib/legion/transport/messages/lex_register.rb,
lib/legion/transport/messages/check_subtask.rb,
lib/legion/transport/queues/region_outbound.rb,
lib/legion/transport/messages/region_re_route.rb

Defined Under Namespace

Modules: Common, Connection, Exchanges, Helpers, Local, Messages, Queues, Settings, Spool, TenantProvisioner, TenantQuota, TenantTopology Classes: ClusterUnavailable, Consumer, Exchange, Message, PoolTimeout, Queue

Constant Summary collapse

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

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



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

def logger
  return @logger unless @logger.nil?

  require 'logger'
  @logger = ::Logger.new($stdout)
  configured_level = begin
    Legion::Settings[:transport][:logger_level]
  rescue StandardError => e
    warn "Transport#logger level lookup failed: #{e.message}"
    '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 



36
37
38
39
40
 
# File 'lib/legion/transport.rb', line 36

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

  Legion::Transport::Settings.default
end