module Legion::Extensions::Helpers::Transport

Public Instance Methods

build_default_exchange() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 33
def build_default_exchange
  exchange = "#{transport_class}::Exchanges::#{lex_const}"
  return Object.const_get(exchange) if transport_class::Exchanges.const_defined? lex_const

  transport_class::Exchanges.const_set(lex_const, Class.new(Legion::Transport::Exchange))
  @default_exchange = Kernel.const_get(exchange)
  @default_exchange
end
default_exchange() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 29
def default_exchange
  @default_exchange ||= build_default_exchange
end
exchanges() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 25
def exchanges
  @exchanges ||= transport_class::Exchanges
end
messages() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 17
def messages
  @messages ||= transport_class::Messages
end
queues() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 21
def queues
  @queues ||= transport_class::Queues
end
transport_class() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 13
def transport_class
  @transport_class ||= lex_class::Transport
end
transport_path() click to toggle source
# File lib/legion/extensions/helpers/transport.rb, line 9
def transport_path
  @transport_path ||= "#{full_path}/transport"
end