lib/legion/transport/queue.rb in legion-transport-1.1.5 vs lib/legion/transport/queue.rb in legion-transport-1.1.6

@@ -18,11 +18,11 @@
         queue = ::Bunny::Queue.new(channel, queue, no_declare: true, passive: true)
         queue.delete(if_empty: true)
       end
 
       def default_options
-        hash = {}
+        hash = Concurrent::Hash.new
         hash[:manual_ack] = true
         hash[:durable] = true
         hash[:exclusive] = false
         hash[:block] = false
         hash[:auto_delete] = false
@@ -33,10 +33,10 @@
         }
         hash
       end
 
       def queue_options
-        {}
+        Concurrent::Hash.new
       end
 
       def queue_name
         ancestor = self.class.ancestors.first.to_s.split('::')
         name = if ancestor[5].scan(/[A-Z]/).length > 1