module Legion::Extensions::Transport::AutoBuild

Public Instance Methods

bind(from, to, options = {}) click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 30
def bind(from, to, options = {})
  from = from.new
  to = to.new
  to.bind(from, routing_key: options[:routing_key]) unless options[:routing_key].nil?
  to.bind(from) if options[:routing_key].nil?
end
build() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 5
def build
  build_e_to_e
  build_e_to_q
end
build_e_to_e() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 22
def build_e_to_e
  e_to_e.each do |binding|
    options = {}
    options[:routing_key] = binding[:routing_key] unless binding[:routing_key].nil?
    bind(binding[:from], binding[:to], options)
  end
end
build_e_to_q() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 14
def build_e_to_q
  e_to_q.each do |binding|
    options = {}
    options[:routing_key] = binding[:routing_key] unless binding[:routing_key].nil?
    bind(binding[:from], binding[:to], options)
  end
end
e_to_e() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 41
def e_to_e
  []
end
e_to_q() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 37
def e_to_q
  []
end
require_exchanges() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 10
def require_exchanges; end
require_queues() click to toggle source
# File lib/legion/extensions/transport/autobuild.rb, line 12
def require_queues; end