lib/bbk/amqp/consumer.rb in bbk-amqp-1.0.0.79546 vs lib/bbk/amqp/consumer.rb in bbk-amqp-1.0.0.81661

@@ -54,10 +54,11 @@
         @queue ||= @channel.queue(queue_name, passive: true)
 
         subscribe_opts = {
           block:        false,
           manual_ack:   true,
-          consumer_tag: options[:consumer_tag]
+          consumer_tag: options[:consumer_tag],
+          exclusive: options.fetch(:exclusive, false)
         }.compact
 
         logger.info 'Starting...'
         @subscription = queue.subscribe(subscribe_opts) do |delivery_info, metadata, payload|
           message = Message.new(self, delivery_info, metadata, payload)