Module: Legion::Transport

Extended by:
Logging::Helper
Defined in:
lib/legion/transport.rb,
lib/legion/transport/kafka.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/helper.rb,
lib/legion/transport/routes.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/in_process.rb,
lib/legion/transport/kafka/admin.rb,
lib/legion/transport/queues/node.rb,
lib/legion/transport/helpers/pool.rb,
lib/legion/transport/kafka/errors.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/kafka/consumer.rb,
lib/legion/transport/kafka/defaults.rb,
lib/legion/transport/kafka/producer.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/kafka/incoming_message.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, Helper, Helpers, InProcess, Kafka, Local, Messages, Queues, Routes, Settings, Spool, TenantProvisioner, TenantQuota, TenantTopology Classes: ClusterUnavailable, Consumer, Exchange, Message, PayloadTooLarge, PoolTimeout, Queue

Constant Summary collapse

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

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



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

def logger
  require 'logger'
  @logger ||= ::Logger.new($stdout)
  desired_level = logger_level_value
  @logger.level = desired_level
  @logger
end

.register_routes ⇒ Object 



26
27
28
29
30
31
32
33
 
# File 'lib/legion/transport.rb', line 26

def register_routes
  return unless defined?(Legion::API) && Legion::API.respond_to?(:register_library_routes)

  Legion::API.register_library_routes('transport', Legion::Transport::Routes)
  log.debug 'Legion::Transport routes registered with API'
rescue StandardError => e
  handle_exception(e, level: :warn, operation: 'transport.register_routes')
end

.settings ⇒ Object 



43
44
45
46
47
 
# File 'lib/legion/transport.rb', line 43

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

  Legion::Transport::Settings.default
end