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