lib/legion/extensions/transport.rb in legionio-0.4.2 vs lib/legion/extensions/transport.rb in legionio-0.4.3

- old
+ new

@@ -32,10 +32,10 @@ transport_class.const_set(thing, Module.new) end end def require_transport_items - { 'exchanges': @exchanges, 'queues': @queues, 'consumers': @consumers, 'messages': @messages }.each do |item, obj| + { exchanges: @exchanges, queues: @queues, consumers: @consumers, messages: @messages }.each do |item, obj| Dir[File.expand_path("#{transport_path}/#{item}/*.rb")].sort.each do |file| require file file_name = file.to_s.split('/').last.split('.').first obj.push(file_name) unless obj.include?(file_name) end