# File lib/amqp/queue.rb, line 786 def unsubscribe(opts = {}, &block) @channel.once_open do self.once_declared do if @default_consumer @default_consumer.cancel(opts.fetch(:nowait, true), &block); @default_consumer = nil end end end end